remove busy wait from data_streamer

[aniketmaurya]

Before submitting

• Was this discussed/agreed via a Github issue? (no need for typos and docs improvements)
• Did you read the contributor guideline, Pull Request section?
• Did you make sure to update the docs?
• Did you write any new necessary tests?

What does this PR do?

data_streamer polls the multiprocessing Pipe Connection for new data and busy waiting causes async loop to hang as discovered in #133.

• This PR, removes the busy polling and uses async queue to consume high speed data.

• When speed of LitAPI generator (prediction, let's say a for loop of 1B) then consumption speed of data_streamer fails to keep up that pace and data is lost. This PR makes sure that all the data is consumed in a go whenever it's available.

PR review

Anyone in the community is free to review the PR once the tests have passed.
If we didn't discuss your PR in GitHub issues there's a high chance it will not be merged.

Did you have fun?

Make sure you had fun coding 🙃

[codecov]

Codecov Report

Attention: Patch coverage is 89.28571% with 3 lines in your changes missing coverage. Please review.

Project coverage is 80%. Comparing base (53dd29f) to head (adae805).

Additional details and impacted files

@@         Coverage Diff         @@
##           main   #140   +/-   ##
===================================
  Coverage    80%    80%           
===================================
  Files        13     13           
  Lines       890    903   +13     
===================================
+ Hits        715    726   +11     
- Misses      175    177    +2     

[lantiga]

Looks good, but please address the comments before merging