cloud.orbit.actors.client.streams

Class ClientSideStreamProxyImpl

java.lang.Object

cloud.orbit.actors.client.streams.ClientSideStreamProxyImpl

All Implemented Interfaces:

ActorObserver, ClientObject, ClientSideStreamProxy, Startable

public class ClientSideStreamProxyImpl
extends Object
implements ClientSideStreamProxy, Startable

Constructor Summary

Constructors

Constructor and Description
ClientSideStreamProxyImpl()

Method Summary

Modifier and Type	Method and Description
<T> AsyncStream<T>	getStream(String provider, Class<T> dataClass, String id)
Task<Void>	onNext(String provider, String streamId, Object message)
void	setRuntime(BasicRuntime runtime)
Task<?>	start()
<T> Task<StreamSubscriptionHandle<T>>	subscribe(String provider, Class<T> dataClass, String streamId, AsyncObserver<T> observer)
<T> 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.ActorObserver

getObserverReference, ping

Methods inherited from interface cloud.orbit.lifecycle.Startable

stop

Constructor Detail

ClientSideStreamProxyImpl

public ClientSideStreamProxyImpl()

Method Detail

onNext

public Task<Void> onNext(String provider,
                         String streamId,
                         Object message)

Specified by:

onNext in interface ClientSideStreamProxy

unsubscribe

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

subscribe

public <T> Task<StreamSubscriptionHandle<T>> subscribe(String provider,
                                                       Class<T> dataClass,
                                                       String streamId,
                                                       AsyncObserver<T> observer)

setRuntime

public void setRuntime(BasicRuntime runtime)

start

public Task<?> start()

Specified by:

start in interface Startable

getStream

public <T> AsyncStream<T> getStream(String provider,
                                    Class<T> dataClass,
                                    String id)