Class MetadataApplierImpl

java.lang.Object

io.grpc.CallCredentials.MetadataApplier

io.grpc.internal.MetadataApplierImpl

final class MetadataApplierImpl
extends CallCredentials.MetadataApplier

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MetadataApplierImpl.MetadataApplierListener

Field Summary

Fields

Modifier and Type	Field	Description
private final CallOptions	callOptions
private final Context	ctx
(package private) DelayedStream	delayedStream
(package private) boolean	finalized
private final MetadataApplierImpl.MetadataApplierListener	listener
private final Object	lock
private final MethodDescriptor<?,?>	method
private final Metadata	origHeaders
private ClientStream	returnedStream
private final ClientStreamTracer[]	tracers
private final ClientTransport	transport

Constructor Summary

Constructors

Constructor	Description
MetadataApplierImpl(ClientTransport transport, MethodDescriptor<?,?> method, Metadata origHeaders, CallOptions callOptions, MetadataApplierImpl.MetadataApplierListener listener, ClientStreamTracer[] tracers)

Method Summary

Modifier and Type	Method	Description
void	apply(Metadata headers)	Called when headers are successfully generated.
void	fail(Status status)	Called when there has been an error when preparing the headers.
private void	finalizeWith(ClientStream stream)
(package private) ClientStream	returnStream()	Return a stream on which the RPC will run on.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

transport

private final ClientTransport transport

method

private final MethodDescriptor<?,?> method

origHeaders

private final Metadata origHeaders

callOptions

private final CallOptions callOptions

ctx

private final Context ctx

listener

private final MetadataApplierImpl.MetadataApplierListener listener

tracers

private final ClientStreamTracer[] tracers

lock

private final Object lock

returnedStream

@Nullable
private ClientStream returnedStream

finalized

boolean finalized

delayedStream

DelayedStream delayedStream

Constructor Details

MetadataApplierImpl

MetadataApplierImpl(ClientTransport transport,
 MethodDescriptor<?,?> method,
 Metadata origHeaders,
 CallOptions callOptions,
 MetadataApplierImpl.MetadataApplierListener listener,
 ClientStreamTracer[] tracers)

Method Details

apply

public void apply(Metadata headers)

Description copied from class: CallCredentials.MetadataApplier

Called when headers are successfully generated. They will be merged into the original headers.

Specified by:

apply in class CallCredentials.MetadataApplier

fail

public void fail(Status status)

Description copied from class: CallCredentials.MetadataApplier

Called when there has been an error when preparing the headers. This will fail the RPC.

Specified by:

fail in class CallCredentials.MetadataApplier

finalizeWith

private void finalizeWith(ClientStream stream)

returnStream

ClientStream returnStream()

Return a stream on which the RPC will run on.