public static interface Publisher.Option<V>
Publisher.Option
for a Publisher
.
Publisher Option | Description |
Publisher.OnFailure.Stop |
Default. If an individual Publisher.send(V) invocation fails then stop any further publishing and close the Publisher . |
Publisher.OnFailure.Continue |
If an individual Publisher.send(V) invocation fails then skip that value and continue to publish other values. |
FailOnFull.enabled() |
When the storage size of the unprocessed values on the topic exceed a configured high-units,
the CompletableFuture returned from the Publisher.send(V) invocation should complete exceptionally.
Overrides the default to block completing until the operation completes when space becomes available. |
Publisher.OrderBy.thread() |
Default. Ensure that all values sent from
the same thread are stored sequentially. |
Publisher.OrderBy.none() |
Enforce no specific ordering between sent values allowing
for the greatest level of parallelism |
Publisher.OrderBy.id(int) |
Ensure ordering of sent values across
all threads which share the same id. |
Publisher.OrderBy.value(ToIntFunction) |
Compute the unit-of-order based on the applying this method on sent value |
Publisher.OrderBy.value(Remote.ToIntFunction) |
Compute the unit-of-order based on the applying this method on sent value |