com.aol.micro.server.javaslang.reactive

Class JavaslangValueSubscriber<T>

java.lang.Object

com.aol.micro.server.javaslang.reactive.JavaslangValueSubscriber<T>

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>

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

Constructor Summary

Constructors

Constructor and Description
JavaslangValueSubscriber()

Method Summary

Modifier and Type	Method and Description
javaslang.control.Either<java.lang.Throwable,T>	either()
void	onComplete()
void	onError(java.lang.Throwable t)
void	onNext(T t)
void	onSubscribe(org.reactivestreams.Subscription s)
javaslang.control.Option<T>	option()
static <T> JavaslangValueSubscriber<T>	subscriber() A reactive-streams subscriber that can generate a Javaslang value type
javaslang.control.Try<T>	tryValue()

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaslangValueSubscriber

public JavaslangValueSubscriber()

Method Detail

subscriber

public static <T> JavaslangValueSubscriber<T> subscriber()

A reactive-streams subscriber that can generate a Javaslang value type

Returns:

JavaslangValueSubscriber

option

public javaslang.control.Option<T> option()

tryValue

public javaslang.control.Try<T> tryValue()

either

public javaslang.control.Either<java.lang.Throwable,T> either()

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>