coroutines-reactive no longer allows for Publisher.openSubscription(): ReceiveChannel
Implemented a hot flow via the Stream.Observer interface in order to agree with Scarlet implementation, ideally this would be a cold flow that opens to connect however since the connection state is unknown it has to be hot. This is also in agreement with the previous openSubscription() usage
implemented FlowStreamAdapter to allow for interfaces which return flow rather than channels, fun observeEvents(): Flow<Event>
aaronweihe
commented
2 years ago
Adds coroutine 1.6.0 support to scarlet
Publisher.openSubscription(): ReceiveChannelStream.Observerinterface in order to agree with Scarlet implementation, ideally this would be a cold flow that opens to connect however since the connection state is unknown it has to be hot. This is also in agreement with the previousopenSubscription()usageFlowStreamAdapterto allow for interfaces which return flow rather than channels,fun observeEvents(): Flow<Event>169
163
27