SimpleStreamProxyObject (Orbit Runtime 1.11.3-mrkt API)

All Implemented Interfaces:: ActorObserver, AsyncObserver<T>, SimpleStreamProxy<T>

public class SimpleStreamProxyObject<T>
extends Object
implements SimpleStreamProxy<T>

Constructors
Constructor and Description
`SimpleStreamProxyObject(SimpleStreamExtension provider, SimpleStream streamActorRef)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`Task<Void>`	`onError(Exception ex)`
`Task<Void>`	`onNext(T data, StreamSequenceToken sequenceToken)`
`Task<StreamSubscriptionHandle<T>>`	`subscribe(AsyncObserver<T> observer)`
`Task<Void>`	`unsubscribe(String handle)`

Methods inherited from interface cloud.orbit.actors.ActorObserver
getObserverReference, ping

public SimpleStreamProxyObject(SimpleStreamExtension provider,
                               SimpleStream streamActorRef)

public Task<Void> onNext(T data,
                         StreamSequenceToken sequenceToken)

public Task<StreamSubscriptionHandle<T>> subscribe(AsyncObserver<T> observer)

public Task<Void> unsubscribe(String handle)

Class SimpleStreamProxyObject<T>