WebSocketSubscriber 的 onClose 什么时候会被回调？ about rxwebsocket HOT 5 CLOSED

public class NotificationService extends Service {
    public static void serviceStart(Context context) {
        Intent intent = new Intent(context, NotificationService.class);
        context.startService(intent);
    }

    public static void serviceStop(Context context) {
        Intent intent = new Intent(context, NotificationService.class);
        context.stopService(intent);
    }

    private static final String TAG = "NotificationService";
    // 网上的服务器
    private static final String URL_WEB_SOCKET = "ws://121.40.165.18:8800";

    private WebSocketSubscriber mWebSocketSubscriber;

    @Override
    public void onCreate() {
        super.onCreate();
        Config config = new Config.Builder().setShowLog(true).setReconnectInterval(5, TimeUnit.SECONDS).build();
        RxWebSocket.setConfig(config);
        mWebSocketSubscriber = new WebSocketSubscriber() {
            @Override
            protected void onOpen(WebSocket webSocket) {
                Log.d(TAG, "RxWebSocket opened");
            }

            @Override
            protected void onMessage(String text) {
                Log.d(TAG, "RxWebSocket message: " + text);
            }

            @Override
            protected void onReconnect() {
                Log.d(TAG, "RxWebSocket reconnect");
            }

            @Override
            protected void onClose() {
                Log.d(TAG, "RxWebSocket close");
            }

            @Override
            public void onError(Throwable e) {
                Log.e(TAG, "RxWebSocket error", e);
            }
        };
        Log.d(TAG, "onCreate");
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        Log.d(TAG, "onStartCommand");
        RxWebSocket.get(URL_WEB_SOCKET).subscribe(mWebSocketSubscriber);
        return super.onStartCommand(intent, flags, startId);
    }

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }

    @Override
    public void onDestroy() {
        mWebSocketSubscriber.dispose();
        super.onDestroy();
        Log.d(TAG, "onDestroy");
    }
}