{@inheritDoc}

Adds a {@link ServerTransportFilter}. The order of filters being added is the order they will be executed. @return this @since 1.2.0

Adds a promise for a pending unprotected write. This will be notified after all of the writes complete.

Moves the clock forward, for tests that require moving the clock forward. It is the transport subclass's responsibility to implement this method.

This is more advanced and does not make use of the stub. You should not normally need to do this, but here is how you would.

This is more advanced and does not make use of the stub. You should not normally need to do this, but here is how you would.

Sets the Cronet channel to always use PUT instead of POST. Defaults to false.

Returns {@code true} if any of the given objects are in use. @param objects The objects to consider. @return {@code true} if any of the given objects

Helper for asserting TLS info in SSLSession {@link io.grpc.ServerCall#getAttributes()}.

Sets unimplemented status for method on given response stream for unary call. @param methodDescriptor of method for which error will be thrown. @para

Attach the given security policy to the transport attributes being built. Will be used by the auth interceptor to confirm accept or reject calls. @pa

Blocks until at least one MessageProducer has been provided for reading.

Allow tests to await the outbound header event, which depending on the test case may be necessary (e.g., if we test for a Netty client's outbound head

Returns an auth credential for the Basic scheme.

Called by the runtime prior to the start of a call to provide a reference to the {@link ClientCallStreamObserver} for the outbound stream. This can be

<pre> Simple bidirectional streaming RPC. </pre>

Repeatedly echos each request until the client has no more requests. It performs all work asynchronously on a single thread. It uses ServerCallStreamO