Package 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>

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

Deprecated.

in through use of the AxonServer java connector

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	Description
ResubscribableStreamObserver(io.grpc.stub.StreamObserver<V> delegate, Consumer<Throwable> resubscribe)	Deprecated. Creates the Re-subscribable Stream Observer.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

ResubscribableStreamObserver

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

Deprecated.

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 Details

onNext

public void onNext(V value)

Deprecated.

Specified by:

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

onError

public void onError(Throwable throwable)

Deprecated.

Specified by:

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

onCompleted

public void onCompleted()

Deprecated.

Specified by:

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