Interface TestStreamTracer

All Known Implementing Classes:
TestClientStreamTracer, TestServerStreamTracer, TestStreamTracer.TestBaseStreamTracer

public interface TestStreamTracer
A StreamTracer suitable for testing.
  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static class 
    A StreamTracer suitable for testing.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Waits for the stream to be done.
    boolean
    await(long timeout, TimeUnit timeUnit)
    Waits for the stream to be done.
    long
    Returns to sum of all sizes passed to StreamTracer.inboundUncompressedSize(long).
    long
    Returns to sum of all sizes passed to StreamTracer.inboundWireSize(long).
    long
    Returns to sum of al sizes passed to StreamTracer.outboundUncompressedSize(long).
    long
    Returns to sum of all sizes passed to StreamTracer.outboundWireSize(long).
    io.grpc.Status
    Returns the status passed to StreamTracer.streamClosed(io.grpc.Status).
    Returns the next captured outbound message event.
    Returns the next captured outbound message event.
    void
    Sets whether to fail on unexpected duplicate calls to callback methods.
  • Method Details

    • await

      void await() throws InterruptedException
      Waits for the stream to be done.
      Throws:
      InterruptedException
    • await

      boolean await(long timeout, TimeUnit timeUnit) throws InterruptedException
      Waits for the stream to be done.
      Throws:
      InterruptedException
    • getStatus

      io.grpc.Status getStatus()
      Returns the status passed to StreamTracer.streamClosed(io.grpc.Status).
    • getInboundWireSize

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

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

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

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

      void setFailDuplicateCallbacks(boolean fail)
      Sets whether to fail on unexpected duplicate calls to callback methods.
    • nextOutboundEvent

      @Nullable String nextOutboundEvent()
      Returns the next captured outbound message event.
    • nextInboundEvent

      String nextInboundEvent()
      Returns the next captured outbound message event.