Package io.grpc.xds

Class FaultFilter.FailingClientCall<ReqT,​RespT>

  • Enclosing class:
    FaultFilter

    private final class FaultFilter.FailingClientCall<ReqT,​RespT>
    extends io.grpc.ClientCall<ReqT,​RespT>
    An implementation of ClientCall that fails when started.
    • Nested Class Summary

      • Nested classes/interfaces inherited from class io.grpc.ClientCall

        io.grpc.ClientCall.Listener<T extends java.lang.Object>
    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) java.util.concurrent.Executor callExecutor  
      (package private) io.grpc.Context context  
      (package private) io.grpc.Status error  
    • Constructor Summary

      Constructors 
      Constructor Description
      FailingClientCall​(io.grpc.Status error, java.util.concurrent.Executor callExecutor)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel​(java.lang.String message, java.lang.Throwable cause)  
      void halfClose()  
      void request​(int numMessages)  
      void sendMessage​(ReqT message)  
      void start​(io.grpc.ClientCall.Listener<RespT> listener, io.grpc.Metadata headers)  
      • Methods inherited from class io.grpc.ClientCall

        getAttributes, isReady, setMessageCompression
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • error

        final io.grpc.Status error
      • callExecutor

        final java.util.concurrent.Executor callExecutor
      • context

        final io.grpc.Context context
    • Constructor Detail

      • FailingClientCall

        FailingClientCall​(io.grpc.Status error,
                          java.util.concurrent.Executor callExecutor)
    • Method Detail

      • start

        public void start​(io.grpc.ClientCall.Listener<RespT> listener,
                          io.grpc.Metadata headers)
        Specified by:
        start in class io.grpc.ClientCall<ReqT,​RespT>
      • request

        public void request​(int numMessages)
        Specified by:
        request in class io.grpc.ClientCall<ReqT,​RespT>
      • cancel

        public void cancel​(java.lang.String message,
                           java.lang.Throwable cause)
        Specified by:
        cancel in class io.grpc.ClientCall<ReqT,​RespT>
      • halfClose

        public void halfClose()
        Specified by:
        halfClose in class io.grpc.ClientCall<ReqT,​RespT>
      • sendMessage

        public void sendMessage​(ReqT message)
        Specified by:
        sendMessage in class io.grpc.ClientCall<ReqT,​RespT>