nats-rx:基于RxJava的NATS的客户端

客户端接收 这是一个基于RxJava的简单NATS客户端。 安装 repositories { .. . maven { url ' https://jitpack.io ' } } dependencies { implementation ' com.github.xy02:nats-rx:0.6.5 ' } 用法 // connect IConnection nc = new Connection ( new Options ()); // subscribe message Disposable sd = nc . subscribeMsg( " test " ) .doOnNext(msg - > System . out . printf( " subject:%s, body length:%d