V
- the type of values passed through the stream@Deprecated public class ResubscribableStreamObserver<V> extends Object implements io.grpc.stub.StreamObserver<V>
StreamObserver
that re-subscribes on error received (if other side is still available).Constructor and Description |
---|
ResubscribableStreamObserver(io.grpc.stub.StreamObserver<V> delegate,
Consumer<Throwable> resubscribe)
Deprecated.
Creates the Re-subscribable Stream Observer.
|
Modifier and Type | Method and Description |
---|---|
void |
onCompleted()
Deprecated.
|
void |
onError(Throwable throwable)
Deprecated.
|
void |
onNext(V value)
Deprecated.
|
public ResubscribableStreamObserver(io.grpc.stub.StreamObserver<V> delegate, Consumer<Throwable> resubscribe)
delegate
- the StreamObserver to delegate callsresubscribe
- the re-subscription consumer - should implement the actual re-subscriptionpublic void onNext(V value)
onNext
in interface io.grpc.stub.StreamObserver<V>
public void onError(Throwable throwable)
onError
in interface io.grpc.stub.StreamObserver<V>
public void onCompleted()
onCompleted
in interface io.grpc.stub.StreamObserver<V>
Copyright © 2010–2023. All rights reserved.