Class TestStreamTracer.TestBaseStreamTracer

java.lang.Object

io.grpc.StreamTracer

io.grpc.internal.testing.TestStreamTracer.TestBaseStreamTracer

All Implemented Interfaces:

TestStreamTracer

Enclosing interface:

TestStreamTracer

public static class TestStreamTracer.TestBaseStreamTracer
extends io.grpc.StreamTracer
implements TestStreamTracer

A StreamTracer suitable for testing.

Nested Class Summary

Nested classes/interfaces inherited from interface TestStreamTracer

TestStreamTracer.TestBaseStreamTracer

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicBoolean	failDuplicateCallbacks
protected final LinkedBlockingQueue<String>	inboundEvents
protected final AtomicLong	inboundUncompressedSize
protected final AtomicLong	inboundWireSize
protected final LinkedBlockingQueue<String>	outboundEvents
protected final AtomicLong	outboundUncompressedSize
protected final AtomicLong	outboundWireSize
protected final CountDownLatch	streamClosed
protected final AtomicReference<Throwable>	streamClosedStack
protected final AtomicReference<io.grpc.Status>	streamClosedStatus

Constructor Summary

Constructors

Constructor	Description
TestBaseStreamTracer()

Method Summary

Modifier and Type	Method	Description
void	await()	Waits for the stream to be done.
boolean	await(long timeout, TimeUnit timeUnit)	Waits for the stream to be done.
long	getInboundUncompressedSize()	Returns to sum of all sizes passed to StreamTracer.inboundUncompressedSize(long).
long	getInboundWireSize()	Returns to sum of all sizes passed to StreamTracer.inboundWireSize(long).
long	getOutboundUncompressedSize()	Returns to sum of al sizes passed to StreamTracer.outboundUncompressedSize(long).
long	getOutboundWireSize()	Returns to sum of all sizes passed to StreamTracer.outboundWireSize(long).
io.grpc.Status	getStatus()	Returns the status passed to StreamTracer.streamClosed(Status).
void	inboundMessage(int seqNo)
void	inboundMessageRead(int seqNo, long optionalWireSize, long optionalUncompressedSize)
void	inboundUncompressedSize(long bytes)
void	inboundWireSize(long bytes)
String	nextInboundEvent()	Returns the next captured outbound message event.
String	nextOutboundEvent()	Returns the next captured outbound message event.
void	outboundMessage(int seqNo)
void	outboundMessageSent(int seqNo, long optionalWireSize, long optionalUncompressedSize)
void	outboundUncompressedSize(long bytes)
void	outboundWireSize(long bytes)
void	setFailDuplicateCallbacks(boolean fail)	Sets whether to fail on unexpected duplicate calls to callback methods.
void	streamClosed(io.grpc.Status status)

Methods inherited from class Object

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

Field Details

outboundWireSize

protected final AtomicLong outboundWireSize

inboundWireSize

protected final AtomicLong inboundWireSize

outboundUncompressedSize

protected final AtomicLong outboundUncompressedSize

inboundUncompressedSize

protected final AtomicLong inboundUncompressedSize

outboundEvents

protected final LinkedBlockingQueue<String> outboundEvents

inboundEvents

protected final LinkedBlockingQueue<String> inboundEvents

streamClosedStatus

protected final AtomicReference<io.grpc.Status> streamClosedStatus

streamClosedStack

protected final AtomicReference<Throwable> streamClosedStack

streamClosed

protected final CountDownLatch streamClosed

failDuplicateCallbacks

protected final AtomicBoolean failDuplicateCallbacks

Constructor Details

TestBaseStreamTracer

public TestBaseStreamTracer()

Method Details

await

public void await()
           throws InterruptedException

Description copied from interface: TestStreamTracer

Waits for the stream to be done.

Specified by:

await in interface TestStreamTracer

Throws:

InterruptedException

await

public boolean await(long timeout,
 TimeUnit timeUnit)
              throws InterruptedException

Description copied from interface: TestStreamTracer

Waits for the stream to be done.

Specified by:

await in interface TestStreamTracer

Throws:

InterruptedException

getStatus

public io.grpc.Status getStatus()

Description copied from interface: TestStreamTracer

Returns the status passed to StreamTracer.streamClosed(Status).

Specified by:

getStatus in interface TestStreamTracer

getInboundWireSize

public long getInboundWireSize()

Description copied from interface: TestStreamTracer

Returns to sum of all sizes passed to StreamTracer.inboundWireSize(long).

Specified by:

getInboundWireSize in interface TestStreamTracer

getInboundUncompressedSize

public long getInboundUncompressedSize()

Description copied from interface: TestStreamTracer

Returns to sum of all sizes passed to StreamTracer.inboundUncompressedSize(long).

Specified by:

getInboundUncompressedSize in interface TestStreamTracer

getOutboundWireSize

public long getOutboundWireSize()

Description copied from interface: TestStreamTracer

Returns to sum of all sizes passed to StreamTracer.outboundWireSize(long).

Specified by:

getOutboundWireSize in interface TestStreamTracer

getOutboundUncompressedSize

public long getOutboundUncompressedSize()

Description copied from interface: TestStreamTracer

Returns to sum of al sizes passed to StreamTracer.outboundUncompressedSize(long).

Specified by:

getOutboundUncompressedSize in interface TestStreamTracer

outboundWireSize

public void outboundWireSize(long bytes)

Overrides:

outboundWireSize in class io.grpc.StreamTracer

inboundWireSize

public void inboundWireSize(long bytes)

Overrides:

inboundWireSize in class io.grpc.StreamTracer

outboundUncompressedSize

public void outboundUncompressedSize(long bytes)

Overrides:

outboundUncompressedSize in class io.grpc.StreamTracer

inboundUncompressedSize

public void inboundUncompressedSize(long bytes)

Overrides:

inboundUncompressedSize in class io.grpc.StreamTracer

streamClosed

public void streamClosed(io.grpc.Status status)

Overrides:

streamClosed in class io.grpc.StreamTracer

inboundMessage

public void inboundMessage(int seqNo)

Overrides:

inboundMessage in class io.grpc.StreamTracer

outboundMessage

public void outboundMessage(int seqNo)

Overrides:

outboundMessage in class io.grpc.StreamTracer

outboundMessageSent

public void outboundMessageSent(int seqNo,
 long optionalWireSize,
 long optionalUncompressedSize)

Overrides:

outboundMessageSent in class io.grpc.StreamTracer

inboundMessageRead

public void inboundMessageRead(int seqNo,
 long optionalWireSize,
 long optionalUncompressedSize)

Overrides:

inboundMessageRead in class io.grpc.StreamTracer

setFailDuplicateCallbacks

public void setFailDuplicateCallbacks(boolean fail)

Description copied from interface: TestStreamTracer

Sets whether to fail on unexpected duplicate calls to callback methods.

Specified by:

setFailDuplicateCallbacks in interface TestStreamTracer

nextOutboundEvent

public String nextOutboundEvent()

Description copied from interface: TestStreamTracer

Returns the next captured outbound message event.

Specified by:

nextOutboundEvent in interface TestStreamTracer

nextInboundEvent

public String nextInboundEvent()

Description copied from interface: TestStreamTracer

Returns the next captured outbound message event.

Specified by:

nextInboundEvent in interface TestStreamTracer