cloud.orbit.actors.streams.simple

Interface SimpleStreamProxy<T>

All Superinterfaces:

ActorObserver, AsyncObserver<T>

All Known Implementing Classes:

SimpleStreamProxyObject

public interface SimpleStreamProxy<T>
extends ActorObserver, AsyncObserver<T>

Method Summary

Modifier and Type	Method and Description
Task<Void>	onError(Exception ex)
Task<Void>	onNext(T data, StreamSequenceToken sequenceToken)

Methods inherited from interface cloud.orbit.actors.ActorObserver

getObserverReference, ping

Method Detail

onNext

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

Specified by:

onNext in interface AsyncObserver<T>

onError

Task<Void> onError(Exception ex)

Specified by:

onError in interface AsyncObserver<T>