cloud.orbit.actors.server.streams

Class ServerSideStreamProxyImpl

java.lang.Object

cloud.orbit.actors.server.streams.ServerSideStreamProxyImpl

All Implemented Interfaces:

ActorObserver, ServerSideStreamProxy, Startable

public class ServerSideStreamProxyImpl
extends Object
implements ServerSideStreamProxy, Startable

Constructor Summary

Constructors

Constructor and Description
ServerSideStreamProxyImpl()

Method Summary

Modifier and Type	Method and Description
void	setPeer(ServerPeer peer)
void	setStage(Stage stage)
Task<?>	start()
Task<?>	stop()
<T> Task<StreamSubscriptionHandle<T>>	subscribe(String provider, int dataClassId, String streamId, ClientSideStreamProxy proxy)
<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

Constructor Detail

ServerSideStreamProxyImpl

public ServerSideStreamProxyImpl()

Method Detail

subscribe

public <T> Task<StreamSubscriptionHandle<T>> subscribe(String provider,
                                                       int dataClassId,
                                                       String streamId,
                                                       ClientSideStreamProxy proxy)

Specified by:

subscribe in interface ServerSideStreamProxy

unsubscribe

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

Specified by:

unsubscribe in interface ServerSideStreamProxy

start

public Task<?> start()

Specified by:

start in interface Startable

stop

public Task<?> stop()

Specified by:

stop in interface Startable

setStage

public void setStage(Stage stage)

setPeer

public void setPeer(ServerPeer peer)