SynchronizedStreamObserver (Apache Beam 2.69.0)

java.lang.Object

org.apache.beam.sdk.fn.stream.SynchronizedStreamObserver<V>

All Implemented Interfaces:: org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<V>

public class SynchronizedStreamObserver<V> extends Object implements org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<V>

A StreamObserver which provides synchronous access access to an underlying StreamObserver.

The underlying StreamObserver must not be used by any other clients.

Method Summary

Modifier and Type

Method

Description

void

onCompleted()

void

onError(Throwable t)

void

onNext(V value)

static <V> org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<V>

wrapping(org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<V> underlying)

Create a new SynchronizedStreamObserver which will delegate all calls to the underlying StreamObserver, synchronizing access to that observer.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- wrapping
  
  public static <V> org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<V> wrapping(org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<V> underlying)
  
  Create a new SynchronizedStreamObserver which will delegate all calls to the underlying StreamObserver, synchronizing access to that observer.
- onNext
  
  public void onNext(V value)
  
  Specified by:
  
  onNext in interface org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<V>
- onError
  
  public void onError(Throwable t)
  
  Specified by:
  
  onError in interface org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<V>
- onCompleted
  
  public void onCompleted()
  
  Specified by:
  
  onCompleted in interface org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<V>