| Package | Description |
|---|---|
| org.gradle.messaging.dispatch | |
| org.gradle.messaging.remote.internal | |
| org.gradle.messaging.remote.internal.inet |
| Modifier and Type | Class and Description |
|---|---|
class |
DelayedReceive<T> |
| Modifier and Type | Method and Description |
|---|---|
void |
AsyncReceive.receiveFrom(Receive<? extends T> receive)
Starts receiving from the given receive.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
Connection<T>
A messaging endpoint which allows push-style dispatch and pull-style receive.
|
interface |
DisconnectAwareConnection<T>
A
DisconnectAwareConnection is a connection capable of executing an action when
the other side of connection disconnects before the stop method is called on this connection. |
| Modifier and Type | Class and Description |
|---|---|
class |
DelegatingConnection<T> |
class |
DisconnectAwareConnectionDecorator<T>
A
DisconnectAwareConnection implementation that decorates an existing connection, adding disconnect awareness. |
class |
EagerReceiveBuffer<T>
Continuously consumes from on or more receivers, serialising to an in memory buffer for synchronous consumption.
|
class |
SynchronizedDispatch<T>
Connection decorator that synchronizes dispatching.
|
| Constructor and Description |
|---|
EagerReceiveBuffer(StoppableExecutor executor,
int bufferSize,
Receive<T> receiver) |
EagerReceiveBuffer(StoppableExecutor executor,
int bufferSize,
Receive<T> receiver,
Runnable onReceiversExhausted) |
EagerReceiveBuffer(StoppableExecutor executor,
Receive<T> receiver) |
EagerReceiveBuffer(StoppableExecutor executor,
Receive<T> receiver,
Runnable onReceiversExhausted) |
| Constructor and Description |
|---|
EagerReceiveBuffer(StoppableExecutor executor,
Collection<Receive<T>> receivers) |
EagerReceiveBuffer(StoppableExecutor executor,
Collection<Receive<T>> receivers,
Runnable onReceiversExhausted) |
EagerReceiveBuffer(StoppableExecutor executor,
int bufferSize,
Collection<Receive<T>> receivers) |
EagerReceiveBuffer(StoppableExecutor executor,
int bufferSize,
Collection<Receive<T>> receivers,
Runnable onReceiversExhausted) |
| Modifier and Type | Class and Description |
|---|---|
class |
MulticastConnection<T> |
class |
SocketConnection<T> |
Copyright © 2013. All rights reserved