Package | Description |
---|---|
com.tangosol.net.topic |
Modifier and Type | Class and Description |
---|---|
static class |
Publisher.OrderById<V>
Publisher.OrderBy option ensures ordering of sent values across
all threads which share the same orderId . |
static class |
Publisher.OrderByNone<V>
Publisher.OrderBy option enforces no specific ordering between sent values allowing
for the greatest level of parallelism. |
static class |
Publisher.OrderByThread<V>
Publisher.OrderBy option which ensures that a sequence of sent values issued by a single thread will
complete in order. |
static class |
Publisher.OrderByValue<V>
Publisher.OrderBy option which computes the unit-of-order based on applying
constructor's orderIdFunction parameter on sent value . |
Modifier and Type | Field and Description |
---|---|
protected static Publisher.OrderBy<Object> |
Publisher.OrderByThread.INSTANCE
The thread-order singleton.
|
protected static Publisher.OrderBy<Object> |
Publisher.OrderByNone.INSTANCE
The none-order singleton.
|
Modifier and Type | Method and Description |
---|---|
static Publisher.OrderBy<Object> |
Publisher.OrderBy.id(int nOrderId)
Return an OrderBy that will ensure ordering of
sent values across
all threads which share the same id. |
static Publisher.OrderBy<Object> |
Publisher.OrderBy.none()
Return an OrderBy that will enforce no specific ordering between
sent values allowing for the greatest level of parallelism. |
static Publisher.OrderBy<Object> |
Publisher.OrderBy.thread()
Return an OrderBy that will ensure that all
values sent from
the same thread are stored sequentially. |
static <V> Publisher.OrderBy<V> |
Publisher.OrderBy.value(Remote.ToIntFunction<? super V> supplierOrderId)
Return an OrderBy which will compute the unit-of-order based on the
sent value . |
static <V> Publisher.OrderBy<V> |
Publisher.OrderBy.value(ToIntFunction<? super V> supplierOrderId)
Return an OrderBy which will compute the unit-of-order based on the
sent value . |