Uses of Interface
dev.getelements.elements.rt.AsyncConnection

Packages that use AsyncConnection

Package	Description
dev.getelements.elements.rt
dev.getelements.elements.rt.jeromq
dev.getelements.elements.rt.remote.jeromq

Uses of AsyncConnection in dev.getelements.elements.rt

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

Modifier and Type	Method	Description
AsyncConnection<ContextT,SocketT>	AsyncConnectionGroup.get(int index)	Gets the AsyncConnection at the provided index.

Method parameters in dev.getelements.elements.rt with type arguments of type AsyncConnection

Modifier and Type	Method	Description
void	AsyncConnectionPool.acquireNextAvailableConnection(Consumer<AsyncConnection<ContextT,SocketT>> asyncConnectionConsumer)	Acquires a new AsyncConnection.
AsyncConnectionGroup.Builder<ContextT,BuilderSocketT>	AsyncConnectionGroup.Builder.connection(Function<ContextT,BuilderSocketT> socketSupplier, Consumer<AsyncConnection<ContextT,BuilderSocketT>> asyncConnectionConsumer)	Adds a AsyncConnection with the supplied creation and consumer function.
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	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.
void	AsyncConnection.signal(Consumer<AsyncConnection<ContextT,SocketT>> asyncConnectionConsumer)	Sends a signal to this AsyncConnection.
default <T> CompletionStage<T>	AsyncConnection.signalAndComputeCompletion(Function<AsyncConnection<ContextT,SocketT>,T> asyncConnectionConsumer)	Computes a value on the connection's IO Thread.
default CompletionStage<Void>	AsyncConnection.signalAndComputeCompletionV(Consumer<AsyncConnection<ContextT,SocketT>> asyncConnectionConsumer)	Computes a value on the connection's IO Thread.

Uses of AsyncConnection in dev.getelements.elements.rt.jeromq

Methods in dev.getelements.elements.rt.jeromq that return AsyncConnection

Modifier and Type	Method	Description
AsyncConnection<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>	JeroMQAsyncConnectionGroup.get(int index)

Constructor parameters in dev.getelements.elements.rt.jeromq with type arguments of type AsyncConnection

Modifier	Constructor	Description
	JeroMQAsyncConnectionGroup(List<AsyncConnection<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>> connectionList, BiConsumer<AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>,Consumer<AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>>> signalHandler)

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

Methods in dev.getelements.elements.rt.remote.jeromq with parameters of type AsyncConnection

Modifier and Type	Method	Description
JeroMQAsyncOperation.ConnectionState	JeroMQAsyncOperation.acquire(AsyncConnection<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> connection)	Called when the connection is acquired.

Constructors in dev.getelements.elements.rt.remote.jeromq with parameters of type AsyncConnection

Modifier	Constructor	Description
	JeroMQRemoteInvocation(JeroMQAsyncOperation asyncOperation, AsyncConnection<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> connection, Invocation invocation, PayloadReader payloadReader, PayloadWriter payloadWriter, Map<String,String> mdcContext, Consumer<Object> syncResultConsumer, Consumer<Throwable> syncErrorConsumer, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, InvocationErrorConsumer asyncInvocationErrorConsumer)