Package io.grpc.internal.testing
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 io.grpc.internal.testing.TestStreamTracer
TestStreamTracer.TestBaseStreamTracer
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final AtomicBoolean
protected final LinkedBlockingQueue
<String> protected final AtomicLong
protected final AtomicLong
protected final LinkedBlockingQueue
<String> protected final AtomicLong
protected final AtomicLong
protected final CountDownLatch
protected final AtomicReference
<Throwable> protected final AtomicReference
<io.grpc.Status> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
await()
Waits for the stream to be done.boolean
Waits for the stream to be done.long
Returns to sum of all sizes passed toStreamTracer.inboundUncompressedSize(long)
.long
Returns to sum of all sizes passed toStreamTracer.inboundWireSize(long)
.long
Returns to sum of al sizes passed toStreamTracer.outboundUncompressedSize(long)
.long
Returns to sum of all sizes passed toStreamTracer.outboundWireSize(long)
.io.grpc.Status
Returns the status passed toStreamTracer.streamClosed(io.grpc.Status)
.void
inboundMessage
(int seqNo) void
inboundMessageRead
(int seqNo, long optionalWireSize, long optionalUncompressedSize) void
inboundUncompressedSize
(long bytes) void
inboundWireSize
(long bytes) Returns the next captured outbound message event.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)
-
Field Details
-
outboundWireSize
-
inboundWireSize
-
outboundUncompressedSize
-
inboundUncompressedSize
-
outboundEvents
-
inboundEvents
-
streamClosedStatus
-
streamClosedStack
-
streamClosed
-
failDuplicateCallbacks
-
-
Constructor Details
-
TestBaseStreamTracer
public TestBaseStreamTracer()
-
-
Method Details
-
await
Description copied from interface:TestStreamTracer
Waits for the stream to be done.- Specified by:
await
in interfaceTestStreamTracer
- Throws:
InterruptedException
-
await
Description copied from interface:TestStreamTracer
Waits for the stream to be done.- Specified by:
await
in interfaceTestStreamTracer
- Throws:
InterruptedException
-
getStatus
public io.grpc.Status getStatus()Description copied from interface:TestStreamTracer
Returns the status passed toStreamTracer.streamClosed(io.grpc.Status)
.- Specified by:
getStatus
in interfaceTestStreamTracer
-
getInboundWireSize
public long getInboundWireSize()Description copied from interface:TestStreamTracer
Returns to sum of all sizes passed toStreamTracer.inboundWireSize(long)
.- Specified by:
getInboundWireSize
in interfaceTestStreamTracer
-
getInboundUncompressedSize
public long getInboundUncompressedSize()Description copied from interface:TestStreamTracer
Returns to sum of all sizes passed toStreamTracer.inboundUncompressedSize(long)
.- Specified by:
getInboundUncompressedSize
in interfaceTestStreamTracer
-
getOutboundWireSize
public long getOutboundWireSize()Description copied from interface:TestStreamTracer
Returns to sum of all sizes passed toStreamTracer.outboundWireSize(long)
.- Specified by:
getOutboundWireSize
in interfaceTestStreamTracer
-
getOutboundUncompressedSize
public long getOutboundUncompressedSize()Description copied from interface:TestStreamTracer
Returns to sum of al sizes passed toStreamTracer.outboundUncompressedSize(long)
.- Specified by:
getOutboundUncompressedSize
in interfaceTestStreamTracer
-
outboundWireSize
public void outboundWireSize(long bytes) - Overrides:
outboundWireSize
in classio.grpc.StreamTracer
-
inboundWireSize
public void inboundWireSize(long bytes) - Overrides:
inboundWireSize
in classio.grpc.StreamTracer
-
outboundUncompressedSize
public void outboundUncompressedSize(long bytes) - Overrides:
outboundUncompressedSize
in classio.grpc.StreamTracer
-
inboundUncompressedSize
public void inboundUncompressedSize(long bytes) - Overrides:
inboundUncompressedSize
in classio.grpc.StreamTracer
-
streamClosed
public void streamClosed(io.grpc.Status status) - Overrides:
streamClosed
in classio.grpc.StreamTracer
-
inboundMessage
public void inboundMessage(int seqNo) - Overrides:
inboundMessage
in classio.grpc.StreamTracer
-
outboundMessage
public void outboundMessage(int seqNo) - Overrides:
outboundMessage
in classio.grpc.StreamTracer
-
outboundMessageSent
public void outboundMessageSent(int seqNo, long optionalWireSize, long optionalUncompressedSize) - Overrides:
outboundMessageSent
in classio.grpc.StreamTracer
-
inboundMessageRead
public void inboundMessageRead(int seqNo, long optionalWireSize, long optionalUncompressedSize) - Overrides:
inboundMessageRead
in classio.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 interfaceTestStreamTracer
-
nextOutboundEvent
Description copied from interface:TestStreamTracer
Returns the next captured outbound message event.- Specified by:
nextOutboundEvent
in interfaceTestStreamTracer
-
nextInboundEvent
Description copied from interface:TestStreamTracer
Returns the next captured outbound message event.- Specified by:
nextInboundEvent
in interfaceTestStreamTracer
-