com.aol.cyclops.control

Class Publishers

java.lang.Object

com.aol.cyclops.control.Publishers

public class Publishers
extends java.lang.Object

Utilities for working with reactive-streams Publishers

Constructor Summary

Constructors

Constructor and Description
Publishers()

Method Summary

Modifier and Type	Method and Description
static <T> AnyMSeq<T>	anyM(org.reactivestreams.Publisher<T> flux) Construct an AnyM type from a Publisher.
static <T> java.util.stream.Stream<T>	jdkStream(org.reactivestreams.Publisher<T> pub) Convert a reactive-streams Publisher to a plain java.util.Stream
static <T> ReactiveSeq<T>	stream(org.reactivestreams.Publisher<T> pub) Convert a reactive-streams Publisher to a cyclops-react ReactiveSeq extended Stream type

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Publishers

public Publishers()

Method Detail

anyM

public static <T> AnyMSeq<T> anyM(org.reactivestreams.Publisher<T> flux)

Construct an AnyM type from a Publisher. This allows the Publisher to be manipulated according to a standard interface along with a vast array of other Java Monad implementations

  
    
    AnyMSeq<Integer> publisher = Publishers.anyM(Flux.just(1,2,3));
    AnyMSeq<Integer> transformedPublisher = myGenericOperation(flux);
    
    public AnyMSeq<Integer> myGenericOperation(AnyMSeq<Integer> monad);
 
 

Parameters:

flux - To wrap inside an AnyM

Returns:

AnyMSeq wrapping a flux

stream

public static <T> ReactiveSeq<T> stream(org.reactivestreams.Publisher<T> pub)

Convert a reactive-streams Publisher to a cyclops-react ReactiveSeq extended Stream type

Parameters:

pub - Publisher to convert to a Stream

Returns:

ReactiveSeq

jdkStream

public static <T> java.util.stream.Stream<T> jdkStream(org.reactivestreams.Publisher<T> pub)

Convert a reactive-streams Publisher to a plain java.util.Stream

Parameters:

pub - Publisher to convert to a Stream

Returns:

Stream