Package io.grpc

Class ForwardingServerCallListener<ReqT>

    • Constructor Detail

      • ForwardingServerCallListener

        public ForwardingServerCallListener()
    • Method Detail

      • onMessage

        public void onMessage​(ReqT message)
        Description copied from class: ServerCall.Listener
        A request message has been received. For streaming calls, there may be zero or more request messages.
        Overrides:
        onMessage in class ServerCall.Listener<ReqT>
        Parameters:
        message - a received request message.
      • onCancel

        public void onCancel()
        Description copied from class: ServerCall.Listener
        The call was cancelled and the server is encouraged to abort processing to save resources, since the client will not process any further messages. Cancellations can be caused by timeouts, explicit cancellation by the client, network errors, etc.

        There will be no further callbacks for the call.

        Overrides:
        onCancel in class ServerCall.Listener<ReqT>
      • onReady

        public void onReady()
        Description copied from class: ServerCall.Listener
        This indicates that the call may now be capable of sending additional messages (via ServerCall.sendMessage(RespT)) 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 call.

        Because there is a processing delay to deliver this notification, it is possible for concurrent writes to cause isReady() == false within this callback. Handle "spurious" notifications by checking isReady()'s current value instead of assuming it is now true. If isReady() == false the normal expectations apply, so there would be another onReady() callback.

        Overrides:
        onReady in class ServerCall.Listener<ReqT>