search

clj-commons / manifold

A compatibility layer for event-driven abstractions
1.02k stars 106 forks source link

Implement stream `flatten` operation #178

Closed solatis closed 2 years ago

solatis commented 5 years ago

This implements a flatten function: it flattens sequences put on a stream and propagates them as individual messages.

KingMob commented 3 years ago

@solatis I'm open to adding this, but I'd want to see some tests added, and I'd like to see if using a (mapcat flatten) transducer would be simpler.

KingMob commented 3 years ago

@solatis Any further thoughts on this?

KingMob commented 2 years ago

Closing for lack of activity. A transducer is probably simpler than a new core fn.