Class TestStreamTracer.TestBaseStreamTracer

    • Field Detail

      • outboundWireSize

        protected final java.util.concurrent.atomic.AtomicLong outboundWireSize
      • inboundWireSize

        protected final java.util.concurrent.atomic.AtomicLong inboundWireSize
      • outboundUncompressedSize

        protected final java.util.concurrent.atomic.AtomicLong outboundUncompressedSize
      • inboundUncompressedSize

        protected final java.util.concurrent.atomic.AtomicLong inboundUncompressedSize
      • outboundEvents

        protected final java.util.concurrent.LinkedBlockingQueue<java.lang.String> outboundEvents
      • inboundEvents

        protected final java.util.concurrent.LinkedBlockingQueue<java.lang.String> inboundEvents
      • streamClosedStatus

        protected final java.util.concurrent.atomic.AtomicReference<io.grpc.Status> streamClosedStatus
      • streamClosedStack

        protected final java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> streamClosedStack
      • streamClosed

        protected final java.util.concurrent.CountDownLatch streamClosed
      • failDuplicateCallbacks

        protected final java.util.concurrent.atomic.AtomicBoolean failDuplicateCallbacks
    • Constructor Detail

      • TestBaseStreamTracer

        public TestBaseStreamTracer()
    • 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 interface TestStreamTracer
        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 interface TestStreamTracer
        Throws:
        java.lang.InterruptedException
      • getStatus

        public io.grpc.Status getStatus()
        Description copied from interface: TestStreamTracer
        Returns the status passed to StreamTracer.streamClosed(io.grpc.Status).
        Specified by:
        getStatus in interface TestStreamTracer
      • outboundWireSize

        public void outboundWireSize​(long bytes)
        Overrides:
        outboundWireSize in class io.grpc.StreamTracer
      • inboundWireSize

        public void inboundWireSize​(long bytes)
        Overrides:
        inboundWireSize in class io.grpc.StreamTracer
      • outboundUncompressedSize

        public void outboundUncompressedSize​(long bytes)
        Overrides:
        outboundUncompressedSize in class io.grpc.StreamTracer
      • inboundUncompressedSize

        public void inboundUncompressedSize​(long bytes)
        Overrides:
        inboundUncompressedSize in class io.grpc.StreamTracer
      • streamClosed

        public void streamClosed​(io.grpc.Status status)
        Overrides:
        streamClosed in class io.grpc.StreamTracer
      • inboundMessage

        public void inboundMessage​(int seqNo)
        Overrides:
        inboundMessage in class io.grpc.StreamTracer
      • outboundMessage

        public void outboundMessage​(int seqNo)
        Overrides:
        outboundMessage in class io.grpc.StreamTracer
      • outboundMessageSent

        public void outboundMessageSent​(int seqNo,
                                        long optionalWireSize,
                                        long optionalUncompressedSize)
        Overrides:
        outboundMessageSent in class io.grpc.StreamTracer
      • inboundMessageRead

        public void inboundMessageRead​(int seqNo,
                                       long optionalWireSize,
                                       long optionalUncompressedSize)
        Overrides:
        inboundMessageRead in class io.grpc.StreamTracer