Uses of Interface
dev.getelements.elements.sdk.Subscription

Packages that use Subscription

Package	Description
dev.getelements.elements.rt
dev.getelements.elements.rt.jrpc
dev.getelements.elements.rt.remote
dev.getelements.elements.rt.remote.jeromq
dev.getelements.elements.sdk
dev.getelements.elements.sdk.spi
dev.getelements.elements.sdk.util
dev.getelements.elements.test

Uses of Subscription in dev.getelements.elements.rt

Methods in dev.getelements.elements.rt that return Subscription

Modifier and Type	Method	Description
Subscription	AsyncConnection.onClose(Consumer<AsyncConnection<ContextT,SocketT>> asyncConnectionConsumer)	Registers a Subscription for when the underlying connection was closed.
Subscription	AsyncConnection.onError(Consumer<AsyncConnection<ContextT,SocketT>> asyncConnectionConsumer)	Registers a Subscription for when a socket has encountered an error.
Subscription	ResultHandlerStrategy.onError(Consumer<Throwable> finalResult)	Handles the final error result.
Subscription	ResultHandlerStrategy.onFinalResult(Consumer<Object> finalResult)	Handles the final result.
Subscription	AsyncConnection.onRead(Consumer<AsyncConnection<ContextT,SocketT>> asyncConnectionConsumer)	Registers a Subscription for when a socket has read data.
Subscription	AsyncConnection.onRecycle(Consumer<AsyncConnection<ContextT,SocketT>> pooledAsyncConnectionConsumer)	Subscribes to an event indicating that the connection was recycled.
Subscription	AsyncConnection.onWrite(Consumer<AsyncConnection<ContextT,SocketT>> asyncConnectionConsumer)	Registers a Subscription for when a socket is ready to write data.

Uses of Subscription in dev.getelements.elements.rt.jrpc

Methods in dev.getelements.elements.rt.jrpc that return Subscription

Modifier and Type	Method	Description
Subscription	SingleAsyncResultHandlerStrategy.onError(Consumer<Throwable> finalResult)
Subscription	SingleSyncReturnResultHandlerStrategy.onError(Consumer<Throwable> finalResult)
Subscription	SingleAsyncResultHandlerStrategy.onFinalResult(Consumer<Object> finalResult)
Subscription	SingleSyncReturnResultHandlerStrategy.onFinalResult(Consumer<Object> finalResult)

Uses of Subscription in dev.getelements.elements.rt.remote

Methods in dev.getelements.elements.rt.remote that return Subscription

Modifier and Type	Method	Description
Subscription	InstanceConnectionService.subscribeToConnect(Consumer<InstanceConnectionService.InstanceConnection> onConnect)	Adds a Consumer<InstanceConnectionService.InstanceConnection> that will be called when a new instance has connected to this InstanceConnectionService.
Subscription	InstanceConnectionService.subscribeToDisconnect(Consumer<InstanceConnectionService.InstanceConnection> onDisconnect)	Adds a Consumer<InstanceConnectionService.InstanceConnection> that will be called when a an instance has disconnected from this InstanceConnectionService.
Subscription	InstanceDiscoveryService.subscribeToDiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)	Subscribes to an event that fires when a new host joins the network.
Subscription	JndiSrvInstanceDiscoveryService.subscribeToDiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)
Subscription	SpotifySrvInstanceDiscoveryService.subscribeToDiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)
Subscription	StaticInstanceDiscoveryService.subscribeToDiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)
Subscription	InstanceDiscoveryService.subscribeToUndiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)	Subscribes to an event that fires when a host leaves the network.
Subscription	JndiSrvInstanceDiscoveryService.subscribeToUndiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)
Subscription	SpotifySrvInstanceDiscoveryService.subscribeToUndiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)
Subscription	StaticInstanceDiscoveryService.subscribeToUndiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)

Uses of Subscription in dev.getelements.elements.rt.remote.jeromq

Methods in dev.getelements.elements.rt.remote.jeromq that return Subscription

Modifier and Type	Method	Description
Subscription	JeroMQInstanceConnectionService.subscribeToConnect(Consumer<InstanceConnectionService.InstanceConnection> onConnect)
Subscription	JeroMQInstanceConnectionService.subscribeToDisconnect(Consumer<InstanceConnectionService.InstanceConnection> onDisconnect)

Uses of Subscription in dev.getelements.elements.sdk

Methods in dev.getelements.elements.sdk that return Subscription

Modifier and Type	Method	Description
static Subscription	Subscription.begin()	Used to start a chain of Subscription instances.
default Subscription	Subscription.chain(Subscription other)	Chains this Subscription to the other so that both will be unsubscribed at the same time.
Subscription	ElementRegistry.onClose(Consumer<ElementRegistry> onClose)	Adds a Consumer to this ElementRegistry which will get called when it is closed.
Subscription	ElementRegistry.onEvent(Consumer<Event> onEvent)	Adds a Consumer to this ElementRegistry which will get called when an Event is sourced from an Element within this registry.

Methods in dev.getelements.elements.sdk with parameters of type Subscription

Modifier and Type	Method	Description
default Subscription	Subscription.chain(Subscription other)	Chains this Subscription to the other so that both will be unsubscribed at the same time.

Uses of Subscription in dev.getelements.elements.sdk.spi

Methods in dev.getelements.elements.sdk.spi that return Subscription

Modifier and Type	Method	Description
Subscription	ElementScopedElementRegistry.onClose(Consumer<ElementRegistry> onClose)
Subscription	RootElementRegistry.onClose(Consumer<ElementRegistry> onClose)
Subscription	ElementScopedElementRegistry.onEvent(Consumer<Event> onEvent)
Subscription	RootElementRegistry.onEvent(Consumer<Event> onEvent)

Uses of Subscription in dev.getelements.elements.sdk.util

Methods in dev.getelements.elements.sdk.util that return Subscription

Modifier and Type	Method	Description
Subscription	ConcurrentDequePublisher.subscribe(BiConsumer<Subscription,? super T> consumer)
Subscription	ConcurrentLockedPublisher.subscribe(BiConsumer<Subscription,? super T> consumer)
Subscription	LinkedPublisher.subscribe(BiConsumer<Subscription,? super T> consumer)
Subscription	Publisher.subscribe(BiConsumer<Subscription,? super T> consumer)	Subscribes to a particular event.
default Subscription	Publisher.subscribe(Consumer<? super T> consumer)	Subscribes to a particular event.

Methods in dev.getelements.elements.sdk.util that return types with arguments of type Subscription

Modifier and Type	Method	Description
Iterator<Subscription>	ConcurrentDequePublisher.iterator()

Method parameters in dev.getelements.elements.sdk.util with type arguments of type Subscription

Modifier and Type	Method	Description
Subscription	ConcurrentDequePublisher.subscribe(BiConsumer<Subscription,? super T> consumer)
Subscription	ConcurrentLockedPublisher.subscribe(BiConsumer<Subscription,? super T> consumer)
Subscription	LinkedPublisher.subscribe(BiConsumer<Subscription,? super T> consumer)
Subscription	Publisher.subscribe(BiConsumer<Subscription,? super T> consumer)	Subscribes to a particular event.

Uses of Subscription in dev.getelements.elements.test

Methods in dev.getelements.elements.test that return Subscription

Modifier and Type	Method	Description
Subscription	EmbeddedInstanceContainer.onClose(Consumer<? super EmbeddedInstanceContainer> consumer)	Registers for a notification when this instance closes.
Subscription	EmbeddedTestService.onClose(Consumer<? super EmbeddedTestService> consumer)	Subscribes to an even that is fired when the service is closed.
Subscription	JeroMQEmbeddedInstanceContainer.onClose(Consumer<? super EmbeddedInstanceContainer> consumer)
Subscription	JeroMQEmbeddedTestService.onClose(Consumer<? super EmbeddedTestService> consumer)