search

rsocket / rsocket-kotlin

RSocket Kotlin multi-platform implementation
http://rsocket.io
Apache License 2.0
552 stars 37 forks source link

Rework request channel #125

Closed whyoleg closed 3 years ago

whyoleg commented 3 years ago

Rework request channel to receive initial payload as additional parameter. The main idea behind this change, is that Flow don't have operator similar to Flux.switchOnFirst which would allow to easily intercept on first element.