org.axonframework.axonserver.connector.util

Class ResubscribableStreamObserver<V>

java.lang.Object

org.axonframework.axonserver.connector.util.ResubscribableStreamObserver<V>

Type Parameters:

V - the type of values passed through the stream

All Implemented Interfaces:

io.grpc.stub.StreamObserver<V>

public class ResubscribableStreamObserver<V>
extends Object
implements io.grpc.stub.StreamObserver<V>

Wrapper around StreamObserver that re-subscribes on error received (if other side is still available).

Since:

4.1.2

Author:

Milan Savic

Constructor Summary

Constructors

Constructor and Description
ResubscribableStreamObserver(io.grpc.stub.StreamObserver<V> delegate, Consumer<Throwable> resubscribe) Creates the Re-subscribable Stream Observer.

Method Summary

Modifier and Type	Method and Description
void	onCompleted()
void	onError(Throwable throwable)
void	onNext(V value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResubscribableStreamObserver

public ResubscribableStreamObserver(io.grpc.stub.StreamObserver<V> delegate,
                                    Consumer<Throwable> resubscribe)

Creates the Re-subscribable Stream Observer.

Parameters:

delegate - the StreamObserver to delegate calls

resubscribe - the re-subscription consumer - should implement the actual re-subscription

Method Detail

onNext

public void onNext(V value)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<V>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface io.grpc.stub.StreamObserver<V>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<V>