C R S T

C

co.paralleluniverse.strands.channels.reactivestreams - package co.paralleluniverse.strands.channels.reactivestreams

Reactive Streams

R

ReactiveStreams - Class in co.paralleluniverse.strands.channels.reactivestreams

Converts between Quasar channels and reactive streams

ReactiveStreams() - Constructor for class co.paralleluniverse.strands.channels.reactivestreams.ReactiveStreams

S

subscribe(int, Channels.OverflowPolicy, Publisher<T>) - Static method in class co.paralleluniverse.strands.channels.reactivestreams.ReactiveStreams

Subscribes to a given Publisher and return a ReceivePort to the subscription.

T

toProcessor(FiberFactory, int, Channels.OverflowPolicy, SuspendableAction2<? extends ReceivePort<? super T>, ? extends SendPort<? extends R>>) - Static method in class co.paralleluniverse.strands.channels.reactivestreams.ReactiveStreams

Turns a transformer into a Publisher.

toProcessor(int, Channels.OverflowPolicy, SuspendableAction2<? extends ReceivePort<? super T>, ? extends SendPort<? extends R>>) - Static method in class co.paralleluniverse.strands.channels.reactivestreams.ReactiveStreams

Turns a transformer into a Publisher.

toPublisher(ReceivePort<T>, FiberFactory) - Static method in class co.paralleluniverse.strands.channels.reactivestreams.ReactiveStreams

Turns a channel to a Publisher.

toPublisher(ReceivePort<T>) - Static method in class co.paralleluniverse.strands.channels.reactivestreams.ReactiveStreams

Turns a channel to a Publisher.

toPublisher(Topic<T>, FiberFactory) - Static method in class co.paralleluniverse.strands.channels.reactivestreams.ReactiveStreams

Turns a topic to a Publisher.

toPublisher(Topic<T>) - Static method in class co.paralleluniverse.strands.channels.reactivestreams.ReactiveStreams

Turns a topic to a Publisher.

C R S T