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
public class TestServerStreamTracer extends io.grpc.ServerStreamTracer implements TestStreamTracer
AServerStreamTracer
suitable for testing.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class io.grpc.ServerStreamTracer
io.grpc.ServerStreamTracer.Factory, io.grpc.ServerStreamTracer.ServerCallInfo<ReqT extends java.lang.Object,RespT extends java.lang.Object>
-
Nested classes/interfaces inherited from interface io.grpc.internal.testing.TestStreamTracer
TestStreamTracer.TestBaseStreamTracer
-
-
Field Summary
Fields Modifier and Type Field Description private TestStreamTracer.TestBaseStreamTracer
delegate
protected java.util.concurrent.atomic.AtomicReference<io.grpc.ServerStreamTracer.ServerCallInfo<?,?>>
serverCallInfo
-
Constructor Summary
Constructors Constructor Description TestServerStreamTracer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
await()
Waits for the stream to be done.boolean
await(long timeout, java.util.concurrent.TimeUnit timeUnit)
Waits for the stream to be done.long
getInboundUncompressedSize()
Returns to sum of all sizes passed toStreamTracer.inboundUncompressedSize(long)
.long
getInboundWireSize()
Returns to sum of all sizes passed toStreamTracer.inboundWireSize(long)
.long
getOutboundUncompressedSize()
Returns to sum of al sizes passed toStreamTracer.outboundUncompressedSize(long)
.long
getOutboundWireSize()
Returns to sum of all sizes passed toStreamTracer.outboundWireSize(long)
.io.grpc.ServerStreamTracer.ServerCallInfo<?,?>
getServerCallInfo()
Returns the ServerCall passed toServerStreamTracer.serverCallStarted(io.grpc.ServerStreamTracer.ServerCallInfo<?, ?>)
.io.grpc.Status
getStatus()
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)
java.lang.String
nextInboundEvent()
Returns the next captured outbound message event.java.lang.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
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)
-
-
-
Field Detail
-
delegate
private final TestStreamTracer.TestBaseStreamTracer delegate
-
serverCallInfo
protected final java.util.concurrent.atomic.AtomicReference<io.grpc.ServerStreamTracer.ServerCallInfo<?,?>> serverCallInfo
-
-
Method Detail
-
await
public void await() throws java.lang.InterruptedException
Description copied from interface:TestStreamTracer
Waits for the stream to be done.- Specified by:
await
in interfaceTestStreamTracer
- Throws:
java.lang.InterruptedException
-
await
public boolean await(long timeout, java.util.concurrent.TimeUnit timeUnit) throws java.lang.InterruptedException
Description copied from interface:TestStreamTracer
Waits for the stream to be done.- Specified by:
await
in interfaceTestStreamTracer
- Throws:
java.lang.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
public java.lang.String nextOutboundEvent()
Description copied from interface:TestStreamTracer
Returns the next captured outbound message event.- Specified by:
nextOutboundEvent
in interfaceTestStreamTracer
-
nextInboundEvent
public java.lang.String 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
-
-