Read bytes from an endpoint and add them as a message to the queue. Blocks if the queue is full.

Attempts to read the required bytes into nextFrame. @return {@code true} if all of the required bytes have been read.

Reason for making this request.

Records a call metric measurement for request cost. If RPC has already finished, this method is no-op. <p>A latter record will overwrite its former n

Captures the ClientCall. Useful for testing {@link ClientCall#getAttributes()}

Records a value for a double-precision histogram metric instrument. @param metricInstrument The histogram metric instrument to record the value again

Records that a request has been dropped as instructed by the remote balancer.

Record a long gauge value. @param value The value to record. @param requiredLabelValues A list of required label values for the metric. @param option

Records a value for a long valued histogram metric instrument. @param metricInstrument The histogram metric instrument to record the value against. @

Async client-streaming example. Sends {@code numPoints} randomly chosen points from {@code features} with a variable delay in between. Prints the stat

Example for testing async client-streaming.

Async client-streaming example. Sends {@code numPoints} randomly chosen points from {@code features} with a variable delay in between. Prints the stat

Captures the request attributes. Useful for testing ServerCalls. {@link ServerCall#getAttributes()}

Release the <i>hard</i> reference for this stats object (previously obtained via {@link LoadStatsManager2#getClusterLocalityStats}). The object may st

Removes given pending stream, used when a pending stream is cancelled.

Removes a server socket.

Rewrites the ServerServiceDefinition replacing one method's definition.

Reports that a message was successfully received. This method is thread safe.

Called by the server to report a stream has started.

<pre> Report results of a QPS test benchmark scenario. </pre>

Very rarely used. Prefer stream.request() instead of this; this method is only necessary if a stream is not available.

Resets the state, preparing to parse a new frame. Must be called between frames.

For subchannels that are in TRANSIENT_FAILURE state, short-circuit the backoff timer and make them reconnect immediately. May also attempt to invoke {