com.aol.cyclops2.types.reactive

Class ReactiveSubscriber<T>

java.lang.Object

com.aol.cyclops2.types.reactive.ReactiveSubscriber<T>

Type Parameters:

T - Subscriber type

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>

public class ReactiveSubscriber<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>

A Subscriber for Observable type event driven Streams that implement backpressure via the reactiveBuffer-streams API

Constructor Summary

Constructors

Constructor and Description
ReactiveSubscriber()

Method Summary

Modifier and Type	Method and Description
boolean	isInitialized()
void	onComplete()
void	onError(java.lang.Throwable t)
void	onNext(T t)
void	onSubscribe(org.reactivestreams.Subscription s)
ReactiveSeq<T>	reactiveStream() ReactiveSubscriber<Integer> sub = Spouts.reactiveSubscriber(); Flux.just(1,2,3).forEachAsync(sub); sub.reactiveStream().forEach(System.out::println); //note JDK Stream based terminal operations may block the current thread //see ReactiveSeq#collectStream ReactiveSeq#foldAll for non-blocking alternatives

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveSubscriber

public ReactiveSubscriber()

Method Detail

reactiveStream

public ReactiveSeq<T> reactiveStream()

    
           ReactiveSubscriber<Integer> sub = Spouts.reactiveSubscriber();

                Flux.just(1,2,3).forEachAsync(sub);
                sub.reactiveStream().forEach(System.out::println);

          //note JDK Stream based terminal operations may block the current thread
          //see ReactiveSeq#collectStream ReactiveSeq#foldAll for non-blocking alternatives
    
 

Returns:

A push-based asychronous event driven Observable-style Stream that implements Backpressure via the reactiveBuffer-streams API

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

onNext

public void onNext(T t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onError

public void onError(java.lang.Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

isInitialized

public boolean isInitialized()