how to flush messages on server

[matt.m...@lucidworks.com]

Hi,

I have an application which receives messages from a client on a bidirectional channel. There’s a case where I’d quickly stop processing messages on the server’s StreamObserver (after I’ve told the client to stop also), but I’m not sure of what’s actually happening to the already recieved messages in gRPC? I’m assuming they are sitting in some Netty queue. Is there a way to throw out those messages, or am I stuck just processing them all anyway? If the latter is the only way, can I somehow control the queue size so it doesn’t take a potentially long time to run through them all?

Thanks,
- Matt

[Carl Mastrangelo]

You should cast from the StreamObserver to a CallStreamObserver and only send messages when isReady() is true.  You can wait for it to become true by setting an isReady handler (look in that class for the exact method name). 

[matt.m...@lucidworks.com]

OK that makes sense. Thanks

- Matt