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