Add `rsocket-cli` command (or example?)

flier commented 5 years ago

I'm working on a more complete example like rsocket-cli, it's rough but works.

Besides, I have some questions about implementation:

How to graceful stop a Flux, Kotlin got takeN but I have to Dispose the subscription that cause a warning log.
How to use request(n) in RSocket or Flux? Since RSocket has Reactive Streams Semantics, how can we control the responses of stream/channel?
How to manage the borrowed ByteBuffer, I always got debug messages like #### bytebuff borrows: 6 or [LEAK] messages count: 1, how to identify where the message was leaked?
It seem no API/implementation for KeepAlive or Lease, right?

jjeffcaii commented 5 years ago

That's Great! 😀

jjeffcaii commented 5 years ago

Current Flux is a basic implementation. I'm working on Flux implementation. Some codes is in another branch. I will consider adding TakeN and Skip operations. My Flux implementation has many wrong designs and it maybe change a lot in the future.

jjeffcaii commented 5 years ago

RequestN has some basic supported with LimitRate.

jjeffcaii commented 5 years ago

Just set your log level to INFO. Debug messages will disappear.

jjeffcaii commented 5 years ago

And sorry my english is pool...

rsocket / rsocket-go

Add `rsocket-cli` command (or example?) #6