Index

A B C D E F G I L M O P R S T U V W Z
All Classes and Interfaces|All Packages

A

AdaptersToFlow - Interface in mutiny.zero.flow.adapters

Adapters from Reactive Streams types to Flow types.

AdaptersToReactiveStreams - Interface in mutiny.zero.flow.adapters

Adapters from Flow types to Reactive Streams types.

always() - Static method in class mutiny.zero.operators.Retry

applyExceptionally(CompletionStage<T>, Function<Throwable, Throwable>) - Static method in interface mutiny.zero.AsyncHelpers

Applies a function on failure to produce another failure.

AsyncHelpers - Interface in mutiny.zero

atMost(int) - Static method in class mutiny.zero.operators.Retry

B

BackpressureStrategy - Enum in mutiny.zero

Define a Tube back-pressure management strategy.

BUFFER - Enum constant in enum mutiny.zero.BackpressureStrategy

Buffer overflowing items until more items are being requested.

C

cancelled() - Method in interface mutiny.zero.Tube

Check if the subscription has been cancelled.

collectToList(Flow.Publisher<T>) - Static method in interface mutiny.zero.PublisherHelpers

Collect all items as a list.

complete() - Method in interface mutiny.zero.Tube

Signal completion and that no more items will be sent.

composeExceptionally(CompletionStage<T>, Function<Throwable, CompletionStage<T>>) - Static method in interface mutiny.zero.AsyncHelpers

Composes the given completion stage on failure.

Concatenate<T> - Class in mutiny.zero.operators

A Flow.Publisher that is the concatenation of several ones.

Concatenate(List<Flow.Publisher<T>>) - Constructor for class mutiny.zero.operators.Concatenate

Create a new concatenation publisher.

create(TubeConfiguration, Consumer<Tube<T>>) - Static method in interface mutiny.zero.ZeroPublisher

Create a new Flow.Publisher with the general-purpose Tube API.

D

DROP - Enum constant in enum mutiny.zero.BackpressureStrategy

Drop items in case of a lack of outstanding requests.

E

empty() - Static method in interface mutiny.zero.ZeroPublisher

Create an empty Flow.Publisher that completes upon subscription without ever sending any item.

ERROR - Enum constant in enum mutiny.zero.BackpressureStrategy

Signal a terminal IllegalStateException as soon as an item is being sent while there is no outstanding request.

F

fail(Throwable) - Method in interface mutiny.zero.Tube

Terminally signal an error.

fromCompletionStage(Supplier<CompletionStage<T>>) - Static method in interface mutiny.zero.ZeroPublisher

Create a Flow.Publisher from a CompletionStage.

fromFailure(Throwable) - Static method in interface mutiny.zero.ZeroPublisher

Create a Flow.Publisher from a known failure.

fromFuture(Supplier<Future<? extends ReadStream<T>>>) - Static method in interface mutiny.zero.vertxpublishers.VertxPublisher

Create a publisher from a Vert.x future stream supplier.

fromGenerator(Supplier<S>, Function<S, Iterator<T>>) - Static method in interface mutiny.zero.ZeroPublisher

Create a Flow.Publisher from a generator over some state.

fromItems(T...) - Static method in interface mutiny.zero.ZeroPublisher

Create a Flow.Publisher from existing items.

fromIterable(Iterable<T>) - Static method in interface mutiny.zero.ZeroPublisher

Create a Flow.Publisher from an iterable object.

fromStream(Supplier<Stream<T>>) - Static method in interface mutiny.zero.ZeroPublisher

Create a Flow.Publisher from a Stream.

fromSupplier(Supplier<ReadStream<T>>) - Static method in interface mutiny.zero.vertxpublishers.VertxPublisher

Create a publisher from a Vert.x stream supplier.

G

getBackpressureStrategy() - Method in class mutiny.zero.TubeConfiguration

Get the back-pressure strategy.

getBufferSize() - Method in class mutiny.zero.TubeConfiguration

Get the buffer size.

I

IGNORE - Enum constant in enum mutiny.zero.BackpressureStrategy

Ignore back-pressure and still send items to the Tube consumer.

L

LATEST - Enum constant in enum mutiny.zero.BackpressureStrategy

Buffer overflowing items in a bounded buffer, but only keep the last values.

M

mutiny.zero - module mutiny.zero

mutiny.zero - package mutiny.zero

Mutiny Zero is minimal API for creating reactive streams compliant Flow.Publisher objects.

mutiny.zero.flow.adapters - module mutiny.zero.flow.adapters

mutiny.zero.flow.adapters - package mutiny.zero.flow.adapters

A set of adapters from Reactive Streams to/from Flow.

mutiny.zero.operators - package mutiny.zero.operators

This package contains a set of simple operator classes that can be useful when working with Flow.Publisher streams.

mutiny.zero.vertxpublishers - module mutiny.zero.vertxpublishers

mutiny.zero.vertxpublishers - package mutiny.zero.vertxpublishers

O

outstandingRequests() - Method in interface mutiny.zero.Tube

Check the number of outstanding requests.

P

processor(Flow.Processor<T, R>) - Static method in interface mutiny.zero.flow.adapters.AdaptersToReactiveStreams

Convert a Flow.Processor to a Processor.

processor(Processor<T, R>) - Static method in interface mutiny.zero.flow.adapters.AdaptersToFlow

Convert a Processor to a Flow.Processor.

publisher(Flow.Publisher<T>) - Static method in interface mutiny.zero.flow.adapters.AdaptersToReactiveStreams

Convert a Flow.Publisher to a Publisher.

publisher(Publisher<T>) - Static method in interface mutiny.zero.flow.adapters.AdaptersToFlow

Convert a Publisher to a Flow.Publisher.

PublisherHelpers - Interface in mutiny.zero

R

Recover<T> - Class in mutiny.zero.operators

A Flow.Publisher that recovers from failure using a Function.

Recover(Flow.Publisher<T>, Function<Throwable, T>) - Constructor for class mutiny.zero.operators.Recover

Build a new recovery publisher.

Retry<T> - Class in mutiny.zero.operators

A Flow.Publisher that retries on failure by re-subscribing to its upstream.

Retry(Flow.Publisher<T>, Predicate<Throwable>) - Constructor for class mutiny.zero.operators.Retry

Build a new retry publisher.

S

Select<T> - Class in mutiny.zero.operators

A Flow.Publisher that selects elements matching a Predicate.

Select(Flow.Publisher<T>, Predicate<T>) - Constructor for class mutiny.zero.operators.Select

Build a new selection publisher.

send(T) - Method in interface mutiny.zero.Tube

Send an item.

subscribe(Flow.Subscriber<? super O>) - Method in class mutiny.zero.operators.Transform

subscribe(Flow.Subscriber<? super T>) - Method in class mutiny.zero.operators.Concatenate

subscribe(Flow.Subscriber<? super T>) - Method in class mutiny.zero.operators.Recover

subscribe(Flow.Subscriber<? super T>) - Method in class mutiny.zero.operators.Retry

subscribe(Flow.Subscriber<? super T>) - Method in class mutiny.zero.operators.Select

subscriber(Flow.Subscriber<T>) - Static method in interface mutiny.zero.flow.adapters.AdaptersToReactiveStreams

Convert a Flow.Subscriber to a Subscriber.

subscriber(Subscriber<T>) - Static method in interface mutiny.zero.flow.adapters.AdaptersToFlow

Convert a Subscriber to a Flow.Subscriber.

subscription(Flow.Subscription) - Static method in interface mutiny.zero.flow.adapters.AdaptersToReactiveStreams

Convert a Flow.Subscription to a Subscription.

subscription(Subscription) - Static method in interface mutiny.zero.flow.adapters.AdaptersToFlow

Convert a Subscription to a Flow.Subscription.

T

toCompletionStage(Flow.Publisher<T>) - Static method in interface mutiny.zero.ZeroPublisher

Create a CompletionStage from a Flow.Publisher.

Transform<I,O> - Class in mutiny.zero.operators

A Flow.Publisher that transforms elements using a Function.

Transform(Flow.Publisher<I>, Function<I, O>) - Constructor for class mutiny.zero.operators.Transform

Build a new transformation publisher.

Tube<T> - Interface in mutiny.zero

A Tube is a general-purpose abstraction for creating Flow.Publisher.

TubeConfiguration - Class in mutiny.zero

Configuration object for creating Tube through ZeroPublisher.create(TubeConfiguration, Consumer).

TubeConfiguration() - Constructor for class mutiny.zero.TubeConfiguration

U

UNBOUNDED_BUFFER - Enum constant in enum mutiny.zero.BackpressureStrategy

Buffer overflowing items until more items are being requested.

V

valueOf(String) - Static method in enum mutiny.zero.BackpressureStrategy

Returns the enum constant of this type with the specified name.

values() - Static method in enum mutiny.zero.BackpressureStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

VertxPublisher - Interface in mutiny.zero.vertxpublishers

Expose Vert.x streams as Reactive Streams compliant publishers.

W

whenCancelled(Runnable) - Method in interface mutiny.zero.Tube

Define an action when the subscription is cancelled.

whenRequested(LongConsumer) - Method in interface mutiny.zero.Tube

Define an action when items are being requested.

whenTerminates(Runnable) - Method in interface mutiny.zero.Tube

Define an action on termination (completion, error or cancellation), typically for cleanup purposes.

withBackpressureStrategy(BackpressureStrategy) - Method in class mutiny.zero.TubeConfiguration

Specify the back-pressure strategy, cannot be null.

withBufferSize(int) - Method in class mutiny.zero.TubeConfiguration

Specify the buffer size must be strictly positive when backpressureStrategy is one of BackpressureStrategy.BUFFER and BackpressureStrategy.LATEST.

Z

ZeroPublisher - Interface in mutiny.zero

Factory methods to simplify the creation of reactive streams compliant Flow.Publisher.

A B C D E F G I L M O P R S T U V W Z
All Classes and Interfaces|All Packages