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

[maoqinglin]

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

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