TeeingReceive{Stream,Channel} and receive_{stream,channel}_from – relevant for this repo?

[ntninja]

As part of my work on ipfs/py-datastore I ended up creating two generic utilities that may be useful in the context of this repository as well:

• TeeingReceive{Stream,Channel}: Wraps an existing trio.Receive{Stream,Channel} and forwards all data received by the wrapped source to an arbitrary number of additional Receive* consumers using an in-memory channel for each.
• receive_{stream,channel}_from: Creates a trio.ReceiveStream from an arbitrary Python/bytes object, iterable or async iterable (returning trio.ReceiveStreams unchanged of course)

Do these sound appropriate for inclusion into this library?

[belm0]

Happy to consider them. Is the implementation in a public repo already by any chance?

I don't have a sense for how general of a need these fill.

[ntninja]

@belm0: Sorry I forgot the link! It's here: https://github.com/ipfs/py-datastore/blob/master/datastore/core/util/stream.py