-
Notifications
You must be signed in to change notification settings - Fork 4k
Closed
Description
Hello,
I'm try to do some streaming service. I do something like this:
// Server-side
@Override
public void signalStream(StreamParams request, StreamObserver<Data> responseObserver) {
final ServerCallStreamObserver callStreamObserver = (ServerCallStreamObserver) responseObserver;
while (!callStreamObserver.isCancelled()) {
// ... prepare data
responseObserver.onNext(data);
}
responseObserver.onCompleted();
}
But if client is goes away or (somehow) isCancelled() not changed either StreamObserver not started throwing.
protobuf 0.15.0
java version "1.8.0_91"
Java(TM) SE Runtime Environment (build 1.8.0_91-b14)
Java HotSpot(TM) 64-Bit Server VM (build 25.91-b14, mixed mode)
Microsoft Windows [Version 10.0.10586]
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels