java - スタックしたヘッダー データを読み取るためのコールバック メソッド。Grpc JAVA の使用

Question

私は Protoc 3.0 を使用しており、Java を使用して GRPC ストリーム データを読み取るためのコールバック メソッドを作成しました。

@Override
    public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
            final MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) {

        return new ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(
                next.newCall(method, callOptions)) {

            @Override
            public void start(Listener<RespT> responseListener, Metadata headers) {


                ClientCall.Listener<RespT> listener = new ClientCall.Listener<RespT>() {

                    @Override
                  public void onHeaders(Metadata headers) {
                        System.out.println("Header received" +headers);             
                        super.onHeaders(headers);

                    }

                };
                super.start(listener, headers);
            }
        };
    }
};

今私が見ているのは、onHeaders メソッドに到達すると、プログラムが無期限に待機することです。これは正常ですか。ヘッダーメソッドが完了したら、通常のストリームデータの読み取りを再開するにはどうすればよいですか?

EDIT-1 チェーンは次のようになります-

@Override
    public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
            final MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) {

        return new ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(
                next.newCall(method, callOptions)) {

            @Override
        public void start(Listener<RespT> responseListener, Metadata headers) {

             responseListener = new SimpleForwardingClientCallListener<RespT>(responseListener) {

                  @Override
                  public void onHeaders(Metadata headers) {
                      System.out.println("Header found"+ headers);
                      super.onHeaders(headers);
                  }
             };


                ClientCall.Listener<RespT> listener = new ClientCall.Listener<RespT>() {

                    @Override
                  public void onHeaders(Metadata headers) {
                        System.out.println("Header received" +headers);             
                        super.onHeaders(headers);

                    }

                };
                super.start(listener, headers);
            }
        };
    }
};