GraphQL subscription not handling exception in Rx3Apollo

I'm using the packages:

// Apollo
implementation "com.apollographql.apollo:apollo-runtime:2.4.1"
implementation "com.apollographql.apollo:apollo-rx3-support:2.4.1"

// RxJava
implementation 'io.reactivex.rxjava3:rxandroid:3.0.0'
implementation 'io.reactivex.rxjava3:rxjava:3.0.4'

And I call function:

    public static Flowable<Response<CallSubscription.Data>> callSubscription(String room) {
        ApolloSubscriptionCall<CallSubscription.Data> call = getApolloClient()
                .subscribe(new CallSubscription(room));

        return Rx3Apollo.from(call)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnNext((dataResponse -> {
                    System.out.println("datat" + dataResponse);
                    if (dataResponse.getErrors() != null) {
                        throw new ApolloException(dataResponse.getErrors().get(0).getMessage());
                    }
                }))
                .filter((dataResponse -> dataResponse.getData() != null));
    }

which is used here:

NetworkService.callSubscription(room).subscribeWith(new DisposableSubscriber<Response<CallSubscription.Data>>() {
            @Override
            protected void onStart() {
                super.onStart();
                System.out.println("onStart");
            }

            @Override
            public void onNext(@NonNull Response<CallSubscription.Data> dataResponse) {
                System.out.println("onNext " + dataResponse);
            }

            @Override
            public void onError(@NonNull Throwable e) {
                System.out.println("onError " + e);
            }

            @Override
            public void onComplete() {
                System.out.println("onComplete ");
            }

        });

And I need to handle exception from NodeJs inside subscription resolver, which is throw new NotFoundException('SOME_ERROR');, but I got just "onStart", nothing else (no "onNext", "onError", "onComplete"). While playground works fine and I'm handling exception there, and query and mutations also work fine with exceptions. What happened with Rx3Apollo subscriptions? it's my mistake or this package has bug?