MCPcopy Create free account
hub / github.com/grpc/grpc-java / AsyncSink

Method AsyncSink

okhttp/src/main/java/io/grpc/okhttp/AsyncSink.java:65–70  ·  view source on GitHub ↗
(SerializingExecutor executor, TransportExceptionHandler exceptionHandler,
      int maxQueuedControlFrames)

Source from the content-addressed store, hash-verified

63 private int queuedControlFrames;
64
65 private AsyncSink(SerializingExecutor executor, TransportExceptionHandler exceptionHandler,
66 int maxQueuedControlFrames) {
67 this.serializingExecutor = checkNotNull(executor, "executor");
68 this.transportExceptionHandler = checkNotNull(exceptionHandler, "exceptionHandler");
69 this.maxQueuedControlFrames = maxQueuedControlFrames;
70 }
71
72 /**
73 * {@code maxQueuedControlFrames} is only effective for frames written with

Callers

nothing calls this directly

Calls 1

checkNotNullMethod · 0.80

Tested by

no test coverage detected