META-INF/
META-INF/MANIFEST.MF
io/
io/grpc/
io/grpc/stub/
io/grpc/stub/AbstractStub.classAbstractStub.java
package io.grpc.stub
public abstract io.grpc.stub.AbstractStub extends java.lang.Object {
private final io.grpc.Channel channel
private final io.grpc.CallOptions callOptions
protected void (io.grpc.Channel)
io.grpc.Channel channel
protected void (io.grpc.Channel, io.grpc.CallOptions)
io.grpc.Channel channel
io.grpc.CallOptions callOptions
public final io.grpc.Channel getChannel ()
public final io.grpc.CallOptions getCallOptions ()
protected abstract io.grpc.stub.AbstractStub build (io.grpc.Channel, io.grpc.CallOptions)
public final io.grpc.stub.AbstractStub withDeadlineNanoTime (java.lang.Long)
Long deadlineNanoTime
public final io.grpc.stub.AbstractStub withDeadlineAfter (long, java.util.concurrent.TimeUnit)
long duration
java.util.concurrent.TimeUnit unit
public final io.grpc.stub.AbstractStub withCompression (java.lang.String)
String compressorName
public final io.grpc.stub.AbstractStub withChannel (io.grpc.Channel)
io.grpc.Channel newChannel
public final transient io.grpc.stub.AbstractStub withInterceptors (io.grpc.ClientInterceptor[])
io.grpc.ClientInterceptor[] interceptors
}
io/grpc/stub/ClientCalls$CallToStreamObserverAdapter.classClientCalls.java
package io.grpc.stub
io.grpc.stub.ClientCalls$CallToStreamObserverAdapter extends java.lang.Object implements io.grpc.stub.StreamObserver {
private final io.grpc.ClientCall call
public void (io.grpc.ClientCall)
io.grpc.ClientCall call
public void onNext (java.lang.Object)
Object value
public void onError (java.lang.Throwable)
Throwable t
public void onCompleted ()
}
io/grpc/stub/ClientCalls$StreamObserverToCallListenerAdapter.classClientCalls.java
package io.grpc.stub
io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter extends io.grpc.ClientCall$Listener {
private final io.grpc.ClientCall call
private final io.grpc.stub.StreamObserver observer
private final boolean streamingResponse
private boolean firstResponseReceived
public void (io.grpc.ClientCall, io.grpc.stub.StreamObserver, boolean)
io.grpc.ClientCall call
io.grpc.stub.StreamObserver observer
boolean streamingResponse
public void onHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public void onMessage (java.lang.Object)
Object message
public void onClose (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
}
io/grpc/stub/ClientCalls$UnaryStreamToFuture.classClientCalls.java
package io.grpc.stub
io.grpc.stub.ClientCalls$UnaryStreamToFuture extends io.grpc.ClientCall$Listener {
private final io.grpc.stub.ClientCalls$GrpcFuture responseFuture
private Object value
public void (io.grpc.stub.ClientCalls$GrpcFuture)
io.grpc.stub.ClientCalls$GrpcFuture responseFuture
public void onHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public void onMessage (java.lang.Object)
Object value
public void onClose (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
}
io/grpc/stub/ClientCalls$GrpcFuture.classClientCalls.java
package io.grpc.stub
io.grpc.stub.ClientCalls$GrpcFuture extends com.google.common.util.concurrent.AbstractFuture {
private final io.grpc.ClientCall call
void (io.grpc.ClientCall)
io.grpc.ClientCall call
protected void interruptTask ()
protected boolean set (java.lang.Object)
Object resp
protected boolean setException (java.lang.Throwable)
Throwable throwable
}
io/grpc/stub/ClientCalls$BlockingResponseStream$QueuingListener.classClientCalls.java
package io.grpc.stub
io.grpc.stub.ClientCalls$BlockingResponseStream$QueuingListener extends io.grpc.ClientCall$Listener {
private boolean done
final io.grpc.stub.ClientCalls$BlockingResponseStream this$0
private void (io.grpc.stub.ClientCalls$BlockingResponseStream)
public void onHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public void onMessage (java.lang.Object)
Object value
public void onClose (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
void (io.grpc.stub.ClientCalls$BlockingResponseStream, io.grpc.stub.ClientCalls$1)
io.grpc.stub.ClientCalls$BlockingResponseStream x0
io.grpc.stub.ClientCalls$1 x1
}
io/grpc/stub/ClientCalls$BlockingResponseStream.classClientCalls.java
package io.grpc.stub
io.grpc.stub.ClientCalls$BlockingResponseStream extends java.lang.Object implements java.util.Iterator {
private final java.util.concurrent.BlockingQueue buffer
private final io.grpc.ClientCall$Listener listener
private final io.grpc.ClientCall call
private final io.grpc.stub.ClientCalls$ThreadlessExecutor threadless
private Object last
private void (io.grpc.ClientCall)
io.grpc.ClientCall call
private void (io.grpc.ClientCall, io.grpc.stub.ClientCalls$ThreadlessExecutor)
io.grpc.ClientCall call
io.grpc.stub.ClientCalls$ThreadlessExecutor threadless
io.grpc.ClientCall$Listener listener ()
private java.lang.Object waitForNext () throws java.lang.InterruptedException
Object next
public boolean hasNext ()
InterruptedException ie
public java.lang.Object next ()
Object tmp
public void remove ()
void (io.grpc.ClientCall, io.grpc.stub.ClientCalls$1)
io.grpc.ClientCall x0
io.grpc.stub.ClientCalls$1 x1
void (io.grpc.ClientCall, io.grpc.stub.ClientCalls$ThreadlessExecutor, io.grpc.stub.ClientCalls$1)
io.grpc.ClientCall x0
io.grpc.stub.ClientCalls$ThreadlessExecutor x1
io.grpc.stub.ClientCalls$1 x2
static java.util.concurrent.BlockingQueue access$400 (io.grpc.stub.ClientCalls$BlockingResponseStream)
io.grpc.stub.ClientCalls$BlockingResponseStream x0
}
io/grpc/stub/ClientCalls$ThreadlessExecutor.classClientCalls.java
package io.grpc.stub
io.grpc.stub.ClientCalls$ThreadlessExecutor extends java.lang.Object implements java.util.concurrent.Executor {
private final java.util.concurrent.BlockingQueue queue
private void ()
public void waitAndDrain () throws java.lang.InterruptedException
Throwable t
Runnable runnable
public void execute (java.lang.Runnable)
Runnable runnable
void (io.grpc.stub.ClientCalls$1)
io.grpc.stub.ClientCalls$1 x0
}
io/grpc/stub/ClientCalls$1.classClientCalls.java
package io.grpc.stub
io.grpc.stub.ClientCalls$1 extends java.lang.Object {
}
io/grpc/stub/ClientCalls.classClientCalls.java
package io.grpc.stub
public io.grpc.stub.ClientCalls extends java.lang.Object {
private static final java.util.logging.Logger log
private void ()
public static void asyncUnaryCall (io.grpc.ClientCall, java.lang.Object, io.grpc.stub.StreamObserver)
io.grpc.ClientCall call
Object param
io.grpc.stub.StreamObserver observer
public static void asyncServerStreamingCall (io.grpc.ClientCall, java.lang.Object, io.grpc.stub.StreamObserver)
io.grpc.ClientCall call
Object param
io.grpc.stub.StreamObserver responseObserver
public static io.grpc.stub.StreamObserver asyncClientStreamingCall (io.grpc.ClientCall, io.grpc.stub.StreamObserver)
io.grpc.ClientCall call
io.grpc.stub.StreamObserver responseObserver
public static io.grpc.stub.StreamObserver asyncBidiStreamingCall (io.grpc.ClientCall, io.grpc.stub.StreamObserver)
io.grpc.ClientCall call
io.grpc.stub.StreamObserver responseObserver
public static java.lang.Object blockingUnaryCall (io.grpc.ClientCall, java.lang.Object)
Throwable t
io.grpc.ClientCall call
Object param
public static java.lang.Object blockingUnaryCall (io.grpc.Channel, io.grpc.MethodDescriptor, io.grpc.CallOptions, java.lang.Object)
InterruptedException e
com.google.common.util.concurrent.ListenableFuture responseFuture
Throwable t
io.grpc.Channel channel
io.grpc.MethodDescriptor method
io.grpc.CallOptions callOptions
Object param
io.grpc.stub.ClientCalls$ThreadlessExecutor executor
io.grpc.ClientCall call
public static java.util.Iterator blockingServerStreamingCall (io.grpc.ClientCall, java.lang.Object)
io.grpc.ClientCall call
Object param
io.grpc.stub.ClientCalls$BlockingResponseStream result
public static java.util.Iterator blockingServerStreamingCall (io.grpc.Channel, io.grpc.MethodDescriptor, io.grpc.CallOptions, java.lang.Object)
io.grpc.Channel channel
io.grpc.MethodDescriptor method
io.grpc.CallOptions callOptions
Object param
io.grpc.stub.ClientCalls$ThreadlessExecutor executor
io.grpc.ClientCall call
io.grpc.stub.ClientCalls$BlockingResponseStream result
public static com.google.common.util.concurrent.ListenableFuture futureUnaryCall (io.grpc.ClientCall, java.lang.Object)
io.grpc.ClientCall call
Object param
io.grpc.stub.ClientCalls$GrpcFuture responseFuture
private static java.lang.Object getUnchecked (java.util.concurrent.Future)
InterruptedException e
java.util.concurrent.ExecutionException e
java.util.concurrent.Future future
private static void asyncUnaryRequestCall (io.grpc.ClientCall, java.lang.Object, io.grpc.stub.StreamObserver, boolean)
io.grpc.ClientCall call
Object param
io.grpc.stub.StreamObserver responseObserver
boolean streamingResponse
private static void asyncUnaryRequestCall (io.grpc.ClientCall, java.lang.Object, io.grpc.ClientCall$Listener, boolean)
Throwable t
io.grpc.ClientCall call
Object param
io.grpc.ClientCall$Listener responseListener
boolean streamingResponse
private static io.grpc.stub.StreamObserver asyncStreamingRequestCall (io.grpc.ClientCall, io.grpc.stub.StreamObserver, boolean)
io.grpc.ClientCall call
io.grpc.stub.StreamObserver responseObserver
boolean streamingResponse
private static void startCall (io.grpc.ClientCall, io.grpc.ClientCall$Listener, boolean)
io.grpc.ClientCall call
io.grpc.ClientCall$Listener responseListener
boolean streamingResponse
static java.util.logging.Logger access$500 ()
static void ()
}
io/grpc/stub/StreamObserver.classStreamObserver.java
package io.grpc.stub
public abstract io.grpc.stub.StreamObserver extends java.lang.Object {
public abstract void onNext (java.lang.Object)
public abstract void onError (java.lang.Throwable)
public abstract void onCompleted ()
}
io/grpc/stub/MetadataUtils$1$1.classMetadataUtils.java
package io.grpc.stub
io.grpc.stub.MetadataUtils$1$1 extends io.grpc.ForwardingClientCall$SimpleForwardingClientCall {
final io.grpc.stub.MetadataUtils$1 this$0
void (io.grpc.stub.MetadataUtils$1, io.grpc.ClientCall)
io.grpc.stub.MetadataUtils$1 this$0
io.grpc.ClientCall x0
public void start (io.grpc.ClientCall$Listener, io.grpc.Metadata)
io.grpc.ClientCall$Listener responseListener
io.grpc.Metadata headers
}
io/grpc/stub/MetadataUtils$1.classMetadataUtils.java
package io.grpc.stub
final io.grpc.stub.MetadataUtils$1 extends java.lang.Object implements io.grpc.ClientInterceptor {
final io.grpc.Metadata val$extraHeaders
void (io.grpc.Metadata)
public io.grpc.ClientCall interceptCall (io.grpc.MethodDescriptor, io.grpc.CallOptions, io.grpc.Channel)
io.grpc.MethodDescriptor method
io.grpc.CallOptions callOptions
io.grpc.Channel next
}
io/grpc/stub/MetadataUtils$2$1$1.classMetadataUtils.java
package io.grpc.stub
io.grpc.stub.MetadataUtils$2$1$1 extends io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener {
final io.grpc.stub.MetadataUtils$2$1 this$1
void (io.grpc.stub.MetadataUtils$2$1, io.grpc.ClientCall$Listener)
io.grpc.stub.MetadataUtils$2$1 this$1
io.grpc.ClientCall$Listener x0
public void onHeaders (io.grpc.Metadata)
io.grpc.Metadata headers
public void onClose (io.grpc.Status, io.grpc.Metadata)
io.grpc.Status status
io.grpc.Metadata trailers
}
io/grpc/stub/MetadataUtils$2$1.classMetadataUtils.java
package io.grpc.stub
io.grpc.stub.MetadataUtils$2$1 extends io.grpc.ForwardingClientCall$SimpleForwardingClientCall {
final io.grpc.stub.MetadataUtils$2 this$0
void (io.grpc.stub.MetadataUtils$2, io.grpc.ClientCall)
io.grpc.stub.MetadataUtils$2 this$0
io.grpc.ClientCall x0
public void start (io.grpc.ClientCall$Listener, io.grpc.Metadata)
io.grpc.ClientCall$Listener responseListener
io.grpc.Metadata headers
}
io/grpc/stub/MetadataUtils$2.classMetadataUtils.java
package io.grpc.stub
final io.grpc.stub.MetadataUtils$2 extends java.lang.Object implements io.grpc.ClientInterceptor {
final java.util.concurrent.atomic.AtomicReference val$headersCapture
final java.util.concurrent.atomic.AtomicReference val$trailersCapture
void (java.util.concurrent.atomic.AtomicReference, java.util.concurrent.atomic.AtomicReference)
public io.grpc.ClientCall interceptCall (io.grpc.MethodDescriptor, io.grpc.CallOptions, io.grpc.Channel)
io.grpc.MethodDescriptor method
io.grpc.CallOptions callOptions
io.grpc.Channel next
}
io/grpc/stub/MetadataUtils.classMetadataUtils.java
package io.grpc.stub
public io.grpc.stub.MetadataUtils extends java.lang.Object {
private void ()
public static io.grpc.stub.AbstractStub attachHeaders (io.grpc.stub.AbstractStub, io.grpc.Metadata)
io.grpc.stub.AbstractStub stub
io.grpc.Metadata extraHeaders
public static io.grpc.ClientInterceptor newAttachHeadersInterceptor (io.grpc.Metadata)
io.grpc.Metadata extraHeaders
public static io.grpc.stub.AbstractStub captureMetadata (io.grpc.stub.AbstractStub, java.util.concurrent.atomic.AtomicReference, java.util.concurrent.atomic.AtomicReference)
io.grpc.stub.AbstractStub stub
java.util.concurrent.atomic.AtomicReference headersCapture
java.util.concurrent.atomic.AtomicReference trailersCapture
public static io.grpc.ClientInterceptor newCaptureMetadataInterceptor (java.util.concurrent.atomic.AtomicReference, java.util.concurrent.atomic.AtomicReference)
java.util.concurrent.atomic.AtomicReference headersCapture
java.util.concurrent.atomic.AtomicReference trailersCapture
}
io/grpc/stub/ServerCalls$UnaryMethod.classServerCalls.java
package io.grpc.stub
public abstract io.grpc.stub.ServerCalls$UnaryMethod extends java.lang.Object implements io.grpc.stub.ServerCalls$UnaryRequestMethod {
}
io/grpc/stub/ServerCalls$ServerStreamingMethod.classServerCalls.java
package io.grpc.stub
public abstract io.grpc.stub.ServerCalls$ServerStreamingMethod extends java.lang.Object implements io.grpc.stub.ServerCalls$UnaryRequestMethod {
}
io/grpc/stub/ServerCalls$ClientStreamingMethod.classServerCalls.java
package io.grpc.stub
public abstract io.grpc.stub.ServerCalls$ClientStreamingMethod extends java.lang.Object implements io.grpc.stub.ServerCalls$StreamingRequestMethod {
}
io/grpc/stub/ServerCalls$BidiStreamingMethod.classServerCalls.java
package io.grpc.stub
public abstract io.grpc.stub.ServerCalls$BidiStreamingMethod extends java.lang.Object implements io.grpc.stub.ServerCalls$StreamingRequestMethod {
}
io/grpc/stub/ServerCalls$1$1.classServerCalls.java
package io.grpc.stub
io.grpc.stub.ServerCalls$1$1 extends io.grpc.stub.ServerCalls$EmptyServerCallListener {
Object request
final io.grpc.stub.ServerCalls$ResponseObserver val$responseObserver
final io.grpc.ServerCall val$call
final io.grpc.stub.ServerCalls$1 this$0
void (io.grpc.stub.ServerCalls$1, io.grpc.stub.ServerCalls$ResponseObserver, io.grpc.ServerCall)
io.grpc.stub.ServerCalls$1 this$0
public void onMessage (java.lang.Object)
Object request
public void onHalfClose ()
public void onCancel ()
}
io/grpc/stub/ServerCalls$1.classServerCalls.java
package io.grpc.stub
final io.grpc.stub.ServerCalls$1 extends java.lang.Object implements io.grpc.ServerCallHandler {
final io.grpc.stub.ServerCalls$UnaryRequestMethod val$method
void (io.grpc.stub.ServerCalls$UnaryRequestMethod)
public io.grpc.ServerCall$Listener startCall (io.grpc.MethodDescriptor, io.grpc.ServerCall, io.grpc.Metadata)
io.grpc.MethodDescriptor methodDescriptor
io.grpc.ServerCall call
io.grpc.Metadata headers
io.grpc.stub.ServerCalls$ResponseObserver responseObserver
}
io/grpc/stub/ServerCalls$2$1.classServerCalls.java
package io.grpc.stub
io.grpc.stub.ServerCalls$2$1 extends io.grpc.stub.ServerCalls$EmptyServerCallListener {
boolean halfClosed
final io.grpc.stub.StreamObserver val$requestObserver
final io.grpc.ServerCall val$call
final io.grpc.stub.ServerCalls$ResponseObserver val$responseObserver
final io.grpc.stub.ServerCalls$2 this$0
void (io.grpc.stub.ServerCalls$2, io.grpc.stub.StreamObserver, io.grpc.ServerCall, io.grpc.stub.ServerCalls$ResponseObserver)
io.grpc.stub.ServerCalls$2 this$0
public void onMessage (java.lang.Object)
Object request
public void onHalfClose ()
public void onCancel ()
}
io/grpc/stub/ServerCalls$2.classServerCalls.java
package io.grpc.stub
final io.grpc.stub.ServerCalls$2 extends java.lang.Object implements io.grpc.ServerCallHandler {
final io.grpc.stub.ServerCalls$StreamingRequestMethod val$method
void (io.grpc.stub.ServerCalls$StreamingRequestMethod)
public io.grpc.ServerCall$Listener startCall (io.grpc.MethodDescriptor, io.grpc.ServerCall, io.grpc.Metadata)
io.grpc.MethodDescriptor methodDescriptor
io.grpc.ServerCall call
io.grpc.Metadata headers
io.grpc.stub.ServerCalls$ResponseObserver responseObserver
io.grpc.stub.StreamObserver requestObserver
}
io/grpc/stub/ServerCalls$UnaryRequestMethod.classServerCalls.java
package io.grpc.stub
abstract io.grpc.stub.ServerCalls$UnaryRequestMethod extends java.lang.Object {
public abstract void invoke (java.lang.Object, io.grpc.stub.StreamObserver)
}
io/grpc/stub/ServerCalls$StreamingRequestMethod.classServerCalls.java
package io.grpc.stub
abstract io.grpc.stub.ServerCalls$StreamingRequestMethod extends java.lang.Object {
public abstract io.grpc.stub.StreamObserver invoke (io.grpc.stub.StreamObserver)
}
io/grpc/stub/ServerCalls$ResponseObserver.classServerCalls.java
package io.grpc.stub
io.grpc.stub.ServerCalls$ResponseObserver extends java.lang.Object implements io.grpc.stub.StreamObserver {
final io.grpc.ServerCall call
volatile boolean cancelled
private boolean sentHeaders
void (io.grpc.ServerCall)
io.grpc.ServerCall call
public void onNext (java.lang.Object)
Object response
public void onError (java.lang.Throwable)
Throwable t
public void onCompleted ()
}
io/grpc/stub/ServerCalls$EmptyServerCallListener.classServerCalls.java
package io.grpc.stub
io.grpc.stub.ServerCalls$EmptyServerCallListener extends io.grpc.ServerCall$Listener {
private void ()
public void onMessage (java.lang.Object)
Object request
public void onHalfClose ()
public void onCancel ()
public void onComplete ()
void (io.grpc.stub.ServerCalls$1)
io.grpc.stub.ServerCalls$1 x0
}
io/grpc/stub/ServerCalls.classServerCalls.java
package io.grpc.stub
public io.grpc.stub.ServerCalls extends java.lang.Object {
private void ()
public static io.grpc.ServerCallHandler asyncUnaryCall (io.grpc.stub.ServerCalls$UnaryMethod)
io.grpc.stub.ServerCalls$UnaryMethod method
public static io.grpc.ServerCallHandler asyncServerStreamingCall (io.grpc.stub.ServerCalls$ServerStreamingMethod)
io.grpc.stub.ServerCalls$ServerStreamingMethod method
public static io.grpc.ServerCallHandler asyncClientStreamingCall (io.grpc.stub.ServerCalls$ClientStreamingMethod)
io.grpc.stub.ServerCalls$ClientStreamingMethod method
public static io.grpc.ServerCallHandler asyncBidiStreamingCall (io.grpc.stub.ServerCalls$BidiStreamingMethod)
io.grpc.stub.ServerCalls$BidiStreamingMethod method
private static io.grpc.ServerCallHandler asyncUnaryRequestCall (io.grpc.stub.ServerCalls$UnaryRequestMethod)
io.grpc.stub.ServerCalls$UnaryRequestMethod method
private static io.grpc.ServerCallHandler asyncStreamingRequestCall (io.grpc.stub.ServerCalls$StreamingRequestMethod)
io.grpc.stub.ServerCalls$StreamingRequestMethod method
}