Class ServerImpl.JumpToApplicationThreadServerStreamListener

  • All Implemented Interfaces:
    ServerStreamListener, StreamListener
    Enclosing class:
    ServerImpl

    static final class ServerImpl.JumpToApplicationThreadServerStreamListener
    extends java.lang.Object
    implements ServerStreamListener
    Dispatches callbacks onto an application-provided executor and correctly propagates exceptions.
    • Field Detail

      • callExecutor

        private final java.util.concurrent.Executor callExecutor
      • cancelExecutor

        private final java.util.concurrent.Executor cancelExecutor
      • tag

        private final io.perfmark.Tag tag
    • Constructor Detail

      • JumpToApplicationThreadServerStreamListener

        public JumpToApplicationThreadServerStreamListener​(java.util.concurrent.Executor executor,
                                                           java.util.concurrent.Executor cancelExecutor,
                                                           ServerStream stream,
                                                           Context.CancellableContext context,
                                                           io.perfmark.Tag tag)
    • Method Detail

      • getListener

        private ServerStreamListener getListener()
        This call MUST be serialized on callExecutor to avoid races.
      • halfClosed

        public void halfClosed()
        Description copied from interface: ServerStreamListener
        Called when the remote side of the transport gracefully closed, indicating the client had no more data to send. No further messages will be received on the stream.

        This method should return quickly, as the same thread may be used to process other streams.

        Specified by:
        halfClosed in interface ServerStreamListener
      • closed

        public void closed​(Status status)
        Description copied from interface: ServerStreamListener
        Called when the stream is fully closed. A status code of Status.Code.OK implies normal termination of the stream. Any other value implies abnormal termination. Since clients cannot send status, the passed status is always library-generated and only is concerned with transport-level stream shutdown (the call itself may have had a failing status, but if the stream terminated cleanly with the status appearing to have been sent, then the passed status here would be OK). This is guaranteed to always be the final call on a listener. No further callbacks will be issued.

        This method should return quickly, as the same thread may be used to process other streams.

        Specified by:
        closed in interface ServerStreamListener
        Parameters:
        status - details about the remote closure
      • closedInternal

        private void closedInternal​(Status status)
      • onReady

        public void onReady()
        Description copied from interface: StreamListener
        This indicates that the transport is now capable of sending additional messages without requiring excessive buffering internally. This event is just a suggestion and the application is free to ignore it, however doing so may result in excessive buffering within the transport.
        Specified by:
        onReady in interface StreamListener