is there an operator to plumb the output of one flow as the input to another (sharedflow)

# coroutines

[william]

is there an operator to plumb the output of one flow as the input to another (sharedflow)

[Zach Klippenstein (he/him) [MOD]]

MutableSharedFlow implements FlowCollector, so you can just do upstreamFlow.collect(sharedFlow)

[william]

cool, haven't seen that before. thanks

[william]

Following up here - it seems like that method is an internal coroutines api

[Zach Klippenstein (he/him) [MOD]]

oh right, can you do upstreamFlow.collect(sharedFlow::emit)?

[william]

yeah i can, was just curious if there was something that was a little cleaner. could create my own extension if i really wanted to. thanks!

[Zach Klippenstein (he/him) [MOD]]

None that i’m aware of but happy to be proven wrong