Package io.grpc.internal.testing
Class TestServerStreamTracer
java.lang.Object
io.grpc.StreamTracer
io.grpc.ServerStreamTracer
io.grpc.internal.testing.TestServerStreamTracer
- All Implemented Interfaces:
TestStreamTracer
A
ServerStreamTracer
suitable for testing.-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.ServerStreamTracer
io.grpc.ServerStreamTracer.Factory, io.grpc.ServerStreamTracer.ServerCallInfo<ReqT,
RespT> Nested classes/interfaces inherited from interface io.grpc.internal.testing.TestStreamTracer
TestStreamTracer.TestBaseStreamTracer
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final TestStreamTracer.TestBaseStreamTracer
protected final AtomicReference
<io.grpc.ServerStreamTracer.ServerCallInfo<?, ?>> -
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.ServerStreamTracer.ServerCallInfo
<?, ?> Returns the ServerCall passed toServerStreamTracer.serverCallStarted(io.grpc.ServerStreamTracer.ServerCallInfo<?, ?>)
.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
serverCallStarted
(io.grpc.ServerStreamTracer.ServerCallInfo<?, ?> callInfo) 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 io.grpc.ServerStreamTracer
filterContext, serverCallStarted
-
Field Details
-
delegate
-
serverCallInfo
-
-
Constructor Details
-
TestServerStreamTracer
public TestServerStreamTracer()
-
-
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
-
getServerCallInfo
public io.grpc.ServerStreamTracer.ServerCallInfo<?,?> getServerCallInfo()Returns the ServerCall passed toServerStreamTracer.serverCallStarted(io.grpc.ServerStreamTracer.ServerCallInfo<?, ?>)
. -
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
-
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
-
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
-
serverCallStarted
public void serverCallStarted(io.grpc.ServerStreamTracer.ServerCallInfo<?, ?> callInfo) - Overrides:
serverCallStarted
in classio.grpc.ServerStreamTracer
-