cloud.orbit.actors.streams.simple

Class SimpleStreamExtension

java.lang.Object

cloud.orbit.actors.streams.simple.SimpleStreamExtension

All Implemented Interfaces:

ActorExtension, StreamProvider, Startable

public class SimpleStreamExtension
extends Object
implements ActorExtension, StreamProvider

Constructor Summary

Constructors

Constructor and Description
SimpleStreamExtension()
SimpleStreamExtension(String name)

Method Summary

Modifier and Type	Method and Description
String	getName()
<T> AsyncStream<T>	getStream(Class<T> dataClass, String id)
<T> SimpleStreamProxyObject<T>	getSubscriber(SimpleStream streamActorRef)
void	setName(String name)

Methods inherited from class java.lang.Object

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

Methods inherited from interface cloud.orbit.lifecycle.Startable

start, stop

Constructor Detail

SimpleStreamExtension

public SimpleStreamExtension()

SimpleStreamExtension

public SimpleStreamExtension(String name)

Method Detail

getStream

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

Specified by:

getStream in interface StreamProvider

getName

public String getName()

Specified by:

getName in interface StreamProvider

setName

public void setName(String name)

getSubscriber

public <T> SimpleStreamProxyObject<T> getSubscriber(SimpleStream streamActorRef)