java.lang.NullPointerException: onNext called with null. Null values are generally not allowed in 2.x operators and sources.

[maoqinglin]

应用直接挂掉了，这个不会调用Consumer的onError方法吗？

直接调用的重连方法 public Observable<String> reconnection(String host, int port) { return connect(host, port) .compose(read()) .retry() .compose(RxSocket.<String>ioToMain()); }