com.aol.cyclops2.types.reactive

Interface PushSubscriber<T>

All Known Implementing Classes:

AsyncSubscriber

public interface PushSubscriber<T>

Method Summary

Modifier and Type	Method and Description
default org.reactivestreams.Subscriber<T>	asSubscriber()
static <T> PushSubscriber<T>	of(org.reactivestreams.Subscriber<T> sub)
void	onComplete()
void	onError(java.lang.Throwable t)
void	onNext(T t)

Method Detail

onNext

void onNext(T t)

onError

void onError(java.lang.Throwable t)

onComplete

void onComplete()

of

static <T> PushSubscriber<T> of(org.reactivestreams.Subscriber<T> sub)

asSubscriber

default org.reactivestreams.Subscriber<T> asSubscriber()