Returns a Writer that calls the given function for apply(), and nothing for reset().

Returns a failed Try that indicates no value was found.

Returns an appropriate representation of "empty" for this read protocol. By default, returns NONE, which is a failure.

Returns a name-based UUID using an implementation of the algorithm defined by RFC 4122 for name-based (version 5) UUIDs.

Returns the name of this data center

Returns whether the ACL is empty, i.e. contains no entries at all.

Returns an Option containing the value of the capture groups, or Option.none() if the regular expression did not match.

Creates and returns a new writer can write instances of T by emitting events of type E.

Results are covariant in E, i.e. a Result<U> is a Result<T> when U extends T.

Returns a QName for a tag in the default namespace.

Matches an exact XML tag, and emits the start and end tags themselves, including any sub-events that make up its body.

Returns whether the given target UUID is registered as having the given right (directly). This function doesn't take any special "admin" rights into a

Attempts to start a new worker which should start at the given start timestamp. If the start timestamp is equal to another worker's timestamp, no wor

Returns a Results that will always return a fixed error object.

Writes an inner protocol multiple times, represented by a {@link io.vavr.collection.Seq}.

Returns a new MaterializerWorkers where the single expected worker has progressed to the given timestamp

Checks whether the given Try indicates that no value was found (by being a failure of NoSuchElementException).

Asserts that the current CompletionStage succeeds within the timeout, and runs further assertions on the success result.

Returns a JSON protocol for an object having a single field, typed to the field's type.

Invokes the given function for every item the inner protocol emits, while emitting a single null as outer value.

Returns the specific subtype of events that this protocol will emit (if known, otherwise E)

<code>required string msg = 1;</code>

Starts a real akka http server for the given route, and then runs the given consumer. After the consumer returns, the server is automatically stopped

Reads and writes a nested protocol optionally, representing it by a {@link io.vavr.control.Option}.

Invokes the given function before calling this writer.

Repeatedly tries to evaluate the given function, re-trying whenever it fails with an AssertionError. Any other exception will be thrown immediately.

Creates a "fake" time-based UUID that sorts as the smallest possible version 1 UUID generated at the provided timestamp. <p/> Such created UUIDs are u

Waits for the specified future to fail, and returns its failure exception (unwrapping any ExecutionException). Throws an assertion error if the futur

Returns a shareable ActorMaterializer that will be the same for all callers for the same ActorSystem.

<code>required string msg = 1;</code>

Returns whether the persistenceId should be replicated to the given data center.

Returns a new command handler that first tries this handler and then {@code other}.

Converts the body to a different type.

Asserts that the current CompletionStage succeeds within the timeout with an object equal to [expectedValue].

Reads an inner protocol multiple times. On reading, creates a {@link io.vavr.collection.Vector} to represent it.

Writes out the given value, and resets the writer.

Creates a flow that feeds each event into [selector], and: - If the selector emits a result, that result, and further results that also match, are fed

Returns a read/write protocol for a CSV format in which only a single column is read or written.

Returns the string which is used when an actual quote (the return value of {{@link #getQuote()}) occurs in a quoted field's value.

Returns a reader that emits a result on every event, the result being the event itself.

A Reader that produces U always produces a subclass of T.