Как сервер gRPC может заметить, что клиент отменил вызов потоковой передачи на стороне сервера?

Я хочу использовать gRPC, чтобы клиенты могли подписываться на события, генерируемые сервером. У меня RPC объявлен так:

rpc Subscribe (SubscribeRequest) returns (stream SubscribeResponse);

где возвращаемый поток бесконечен. Чтобы «отписаться», клиенты отменяют RPC (кстати, есть ли более чистый способ?).

Я понял, как клиент может отменить звонок:

Context.CancellableContext cancellableContext =
         Context.current().withCancellation();
cancellableContext.run(() -> {
   stub.subscribe(request, callback);
});
// do other stuff / wait for reason to unsubscribe
cancellableContext.cancel(new InterruptedException());

Однако сервер, похоже, не замечает, что клиент отменил свой вызов. Я тестирую это на фиктивной реализации сервера:

@Override
public void subscribe(SubscribeRequest request,
                      StreamObserver<SubscribeResponse> responseObserver) {
  // in real code, this will happen in a separate thread.
  while (!Thread.interrupted()) {
    responseObserver.onNext(SubscribeResponse.getDefaultInstance());
  }
}

Сервер с радостью продолжит отправку своих сообщений в эфир. Как сервер может распознать, что вызов был отменен клиентом, и, таким образом, прекратить отправку ответов?