Hi,
stub.ListFeatures(..) will return an object for which you can get the
streamed features. When you destroy that object, the servers "write" object
will fail when doing writeObj.Write(Feature). That way the server knows the
connection
has been severed.
Regards
/R
Den torsdag 20 oktober 2016 kl. 02:08:45 UTC+2 skrev Edmund:
>
> 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/b27faa8a-2a87-4c66-abdb-6c3163c9551c%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
