Arun Aruljothi

The `collect` class does not allow for awaitable sinks. Small example: ```python async def sink_to_something(x): print(x) return await asyncio.sleep(1) source = streamz.Source() collector = source.collect() collector.sink(sink_to_something) for i in range(10):...