RxSocket - socket with reactive style.
Why do this project
Reactive programming has a important concept of stream which allow application scale vertically and apply good multi-thread dispatch for concurrent event.Network programming is designed as many layer for different data types. It's nature and useful if use Reactive Style to implement network data stream.At upper of TCP, the library complete a basic function of Session Layer and Json Presentation Layer.
v0.12.0, RxSocket only support Scala
"com.scalachan" %% "rxsocket" % "0.12.2"
- do logic with reactive style with
- with RPC stream can get a pipe-like socket communicate.
- Asynchronous & Non-blocking
- Json based Server mode make it easy to build TCP service.
- consume data with back-pressure
- custom protocol parser which could be active mode or passive mode
- support heartbeat
- add monitor for net status
- better benchmark