If I have a

ReceiveChannel

, is there a way for me to turn it into a

Flow

?

flow(block)

can probably still work:

val flowFromChan = flow { 
  recvChan.consumeEach(this::emit)
}

Isn’t there a simple

ReceiveChannel<T>.asFlow(): Flow<T>

extension?

yes, that's why I didn't suggest it

flow { 
  recvChan.consumeEach(this::emit)
}

is an option, yes. We do not provide such extension on

ReceiveChannel

because it is not cold (e.g. second

collect

call to such flow will emit zero items) and does not play well with flow semantics. We are currently thinking of alternatives (e.g. some kind of subjects), so feel free to create an issue with your use-case and desired solution

Receive can be broadcast and then the broadcast can be flowed.