cloud.orbit.actors.streams.simple

Class StreamReference<T>

java.lang.Object

cloud.orbit.actors.streams.simple.StreamReference<T>

All Implemented Interfaces:

AsyncStream<T>

public class StreamReference<T>
extends Object
implements AsyncStream<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamReference.SimpleStreamHandle<T>

Field Summary

Fields inherited from interface cloud.orbit.actors.streams.AsyncStream

DEFAULT_PROVIDER

Constructor Summary

Constructors

Constructor and Description
StreamReference(SimpleStreamExtension provider, Class<T> dataClass, String id)

Method Summary

Modifier and Type	Method and Description
Task<Void>	publish(T data)
Task<StreamSubscriptionHandle<T>>	subscribe(AsyncObserver<T> observer, StreamSequenceToken token)
Task<Void>	unsubscribe(StreamSubscriptionHandle<T> handle)

Methods inherited from class java.lang.Object

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

Methods inherited from interface cloud.orbit.actors.streams.AsyncStream

getStream, getStream, subscribe

Constructor Detail

StreamReference

public StreamReference(SimpleStreamExtension provider,
                       Class<T> dataClass,
                       String id)

Method Detail

unsubscribe

public Task<Void> unsubscribe(StreamSubscriptionHandle<T> handle)

Specified by:

unsubscribe in interface AsyncStream<T>

subscribe

public Task<StreamSubscriptionHandle<T>> subscribe(AsyncObserver<T> observer,
                                                   StreamSequenceToken token)

Specified by:

subscribe in interface AsyncStream<T>

publish

public Task<Void> publish(T data)

Specified by:

publish in interface AsyncStream<T>