cloud.orbit.actors.streams.simple

Class SimpleStreamActor

java.lang.Object

cloud.orbit.actors.runtime.AbstractActor<SimpleStreamActor.State>

cloud.orbit.actors.streams.simple.SimpleStreamActor

All Implemented Interfaces:

Actor, SimpleStream

public class SimpleStreamActor
extends AbstractActor<SimpleStreamActor.State>
implements SimpleStream

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimpleStreamActor.State

Field Summary

Fields inherited from class cloud.orbit.actors.runtime.AbstractActor

activation, logger, reference, runtime, state, stateExtension

Constructor Summary

Constructors

Constructor and Description
SimpleStreamActor()

Method Summary

Modifier and Type	Method and Description
Task<?>	activateAsync()
Task<?>	deactivateAsync()
<T> Task<Void>	publish(T data)
Task<String>	subscribe(SimpleStreamProxy subscriber)
Task<Void>	unsubscribe(String handle)

Methods inherited from class cloud.orbit.actors.runtime.AbstractActor

actorIdentity, clearState, createDefaultState, getLogger, getLogger, getStateClass, getStreamProvider, readState, registerReminder, registerTimer, registerTimer, runtimeIdentity, state, unregisterReminder, writeState

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.Actor

cast, deactivate, getClusterActorCount, getIdentity, getIdentity, getReference, getReference

Constructor Detail

SimpleStreamActor

public SimpleStreamActor()

Method Detail

unsubscribe

public Task<Void> unsubscribe(String handle)

Specified by:

unsubscribe in interface SimpleStream

subscribe

public Task<String> subscribe(SimpleStreamProxy subscriber)

Specified by:

subscribe in interface SimpleStream

activateAsync

public Task<?> activateAsync()

Overrides:

activateAsync in class AbstractActor<SimpleStreamActor.State>

deactivateAsync

public Task<?> deactivateAsync()

Overrides:

deactivateAsync in class AbstractActor<SimpleStreamActor.State>

publish

public <T> Task<Void> publish(T data)

Specified by:

publish in interface SimpleStream