Package com.oracle.coherence.grpc

Class LockingStreamObserver<V>

java.lang.Object
com.oracle.coherence.grpc.LockingStreamObserver<V>
Type Parameters:
V - the type of the observer
All Implemented Interfaces:
io.grpc.stub.StreamObserver<V>
public class LockingStreamObserver<V> extends Object implements io.grpc.stub.StreamObserver<V>
A StreamObserver that delegates calls to another StreamObserver under a Lock.

  • Constructor Details

    • LockingStreamObserver

      public LockingStreamObserver(io.grpc.stub.StreamObserver<? super V> delegate)
      Create a LockingStreamObserver.
      Parameters:
      delegate - the StreamObserver to delegate to

  • Method Details

    • onNext

      public void onNext(V value)
      Specified by:
      onNext in interface io.grpc.stub.StreamObserver<V>

    • onError

      public void onError(Throwable t)
      Specified by:
      onError in interface io.grpc.stub.StreamObserver<V>

    • onCompleted

      public void onCompleted()
      Specified by:
      onCompleted in interface io.grpc.stub.StreamObserver<V>

    • isDone

      public boolean isDone()
      Returns true if this observer is complete.
      Returns:
      true if this observer is complete

    • ensureLockingObserver

      public static <T> LockingStreamObserver<T> ensureLockingObserver(io.grpc.stub.StreamObserver<T> observer)
      Ensure that the specified StreamObserver is a safe observer.

      If the specified observer is not an instance of LockingStreamObserver then wrap it in a LockingStreamObserver.

      Type Parameters:
      T - the response type expected by the observer
      Parameters:
      observer - the StreamObserver to test
      Returns:
      a safe StreamObserver