How to know the client cancels/exits in a server-only streaming call

[met-pub]

In a server-only streaming call, when the client exit unexpectedly (like network error), how does the server know (like Exception or signal) and stop the stream?

[uweschaefer]

I'd love to know as well...

[ST-DDT]

I assume this question is probably better suited in the grpc-java repo, because this library does not provide or change the behavior of the grpc-stuff.

[ST-DDT]

There is an example within the grpc code.

The grpc health service has a method called watch, which publishes updates after the initial call.

https://github.com/grpc/grpc-java/blob/master/services/src/main/java/io/grpc/services/HealthServiceImpl.java#L84

Context.current().addListener(
        new CancellationListener() {
            @Override
            // Called when the client has closed the stream
            public void cancelled(Context context) {
                doCleanup();
            }
        },
        MoreExecutors.directExecutor());

Does this answer your question?

[ST-DDT]

I assume the question is answered. If not please leave a comment.