Data Streams with Queues
This feature is no longer supported.Instead people may want to look at the following options:
- Use normal for loops with Client.submit/gather and as_completed
- Use asynchronous async/await code and a few coroutines
- Try out the Streamz project,which has Dask support