Reworked interactions api

rsocket / rsocket-kotlin

RSocket Kotlin multi-platform implementation

http://rsocket.io

Apache License 2.0

552 stars 37 forks source link

Closed whyoleg closed 4 years ago

whyoleg commented 4 years ago

Reworked streams interactions using Flow fusion instead of custom RequestingFlow implementation. Now, requestN semantics is controlled by Flow.buffer(n) operator.
Make MP and F&F suspend (closes #81)
cleanup of internals
kotlin 1.4.10