okumin / influent

A Fluentd server running on the JVM
Apache License 2.0
29 stars 5 forks source link

Reactive Streams support #29

Open okumin opened 7 years ago

okumin commented 7 years ago

Implement back pressure function and Reactive Streams API. http://www.reactive-streams.org/

okumin commented 7 years ago

Divides conversion layers and provides back-pressure between each layers. https://github.com/okumin/influent/issues/9#issuecomment-326953942