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 
    TestStreamTracer.TestBaseStreamTracer
    A StreamTracer suitable for testing.

  • 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).
    String
    nextInboundEvent()
    Returns the next captured outbound message event.
    String
    nextOutboundEvent()
    Returns the next captured outbound message event.
    void
    setFailDuplicateCallbacks(boolean fail)
    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(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.