Package io.grpc

Class ForwardingServerCallListener.SimpleForwardingServerCallListener<ReqT>

java.lang.Object
io.grpc.ServerCall.Listener<ReqT>
io.grpc.ForwardingServerCallListener<ReqT>
io.grpc.ForwardingServerCallListener.SimpleForwardingServerCallListener<ReqT>
Enclosing class:
ForwardingServerCallListener<ReqT>
public abstract static class ForwardingServerCallListener.SimpleForwardingServerCallListener<ReqT> extends ForwardingServerCallListener<ReqT>
A simplified version of ForwardingServerCallListener where subclasses can pass in a ServerCall.Listener as the delegate.

  • Constructor Details

    • SimpleForwardingServerCallListener

      protected SimpleForwardingServerCallListener(ServerCall.Listener<ReqT> delegate)

  • Method Details

    • delegate

      protected ServerCall.Listener<ReqT> delegate()
      Description copied from class: ForwardingServerCallListener
      Returns the delegated ServerCall.Listener.
      Specified by:
      delegate in class ForwardingServerCallListener<ReqT>

    • onHalfClose

      public void onHalfClose()
      Description copied from class: ServerCall.Listener
      The client completed all message sending. However, the call may still be cancelled.
      Overrides:
      onHalfClose in class ServerCall.Listener<ReqT>

    • 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>

    • onComplete

      public void onComplete()
      Description copied from class: ServerCall.Listener
      The call is considered complete and ServerCall.Listener.onCancel() is guaranteed not to be called. However, the client is not guaranteed to have received all messages.

      There will be no further callbacks for the call.

      Overrides:
      onComplete 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>

    • toString

      public String toString()
      Overrides:
      toString in class Object