Blocking stub observers thread interruption; if the thread is interrupted
it will cancel the RPC.
For async stub, you can create a CancellableContext and cancel it:
CancellableContext withCancellation = Context.current().withCancellation();
withCancellation.run(new Runnable() {
@Override public void run() {
stub.listFeatures(rectangle, observer);
}
});
When the RPC completes, make sure to call withCancellation.cancel(null);,
otherwise you can start retaining memory.
When you want to cancel the RPC call withCancellation.cancel(someEx);. The
exception is just used for your own debugging, since without it it would be
hard to tell where cancellations come from.
On Wed, Oct 19, 2016 at 5:08 PM, Edmund <[email protected]> wrote:
> Hello!
>
> I am trying to close a server-side streaming stream by the client but
> cannot seem to find a way to do it without closing the whole connection or
> channel. The proto file has a service like this:
>
> rpc ListFeatures(Rectangle) returns (stream Feature) {}
>
> When I use stub.ListFeatures() it does not return a StreamObserver like a
> bi-directional stream. So I cannot call onComplete() and have the stream
> close without closing the channel.
>
> Any thoughts?
>
> * I also tried using a blockingStub, loop and flag. However, it would get
> stuck in hasNext()when waiting for messages and I cannot break out with a
> flag
>
> --
> You received this message because you are subscribed to the Google Groups "
> grpc.io" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to [email protected].
> To post to this group, send email to [email protected].
> Visit this group at https://groups.google.com/group/grpc-io.
> To view this discussion on the web visit https://groups.google.com/d/
> msgid/grpc-io/31ef938c-f3c1-4a88-a73c-f6f0ae15e1c2%40googlegroups.com
> <https://groups.google.com/d/msgid/grpc-io/31ef938c-f3c1-4a88-a73c-f6f0ae15e1c2%40googlegroups.com?utm_medium=email&utm_source=footer>
> .
> For more options, visit https://groups.google.com/d/optout.
>
--
You received this message because you are subscribed to the Google Groups
"grpc.io" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/grpc-io.
To view this discussion on the web visit
https://groups.google.com/d/msgid/grpc-io/CA%2B4M1oNNmMof9jO%3DY722MYeQT8bjEq%2B6nRuCjgQ04jMaAY-d%3DQ%40mail.gmail.com.
For more options, visit https://groups.google.com/d/optout.
