Closed nimatrueway closed 1 week ago
I looked into how this can be implemented based on Source[T].merge
, and wrote a quick draft implementation of my idea at https://github.com/softwaremill/ox/pull/198
I suspect that having a select
that allows a mutable list of ReceiveClause
so that we can add to the clauses as the parent source generates more children sources will boost performance 🤔
Is there any tool of such nature for
Stream
, I was writing a few examples for my company to compare different Scala streaming libraries (e.g. monixObservable
, fs2Stream
, oxSource
, etc.) that I run into this case.I was just wondering if this is overlooked or is there any solid reason as to not include
flatten
inSource
api?