hu.akarnokd.rxjava2.observables

Class BlockingObservable<T>

java.lang.Object

hu.akarnokd.rxjava2.observables.BlockingObservable<T>

All Implemented Interfaces:

java.lang.Iterable<T>, org.reactivestreams.Publisher<T>

public final class BlockingObservable<T>
extends java.lang.Object
implements org.reactivestreams.Publisher<T>, java.lang.Iterable<T>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BlockingObservable(org.reactivestreams.Publisher<? extends T> source)

Method Summary

Modifier and Type	Method and Description
T	first()
T	first(T defaultValue)
Optional<T>	firstOption()
void	forEach(Consumer<? super T> action)
static <T> BlockingObservable<T>	from(org.reactivestreams.Publisher<? extends T> source)
java.util.Iterator<T>	iterator()
T	last()
T	last(T defaultValue)
Optional<T>	lastOption()
java.lang.Iterable<T>	latest()
java.lang.Iterable<T>	mostRecent(T initialValue)
java.lang.Iterable<T>	next()
void	run() Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
T	single()
T	single(T defaultValue)
void	subscribe() Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
void	subscribe(Consumer<? super T> onNext) Subscribes to the source and calls the given action on the current thread and rethrows any exception wrapped into OnErrorNotImplementedException.
void	subscribe(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError) Subscribes to the source and calls the given actions on the current thread.
void	subscribe(Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete) Subscribes to the source and calls the given actions on the current thread.
void	subscribe(org.reactivestreams.Subscriber<? super T> subscriber) Subscribes to the source and calls the Subscriber methods on the current thread.
java.util.concurrent.Future<T>	toFuture()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

BlockingObservable

protected BlockingObservable(org.reactivestreams.Publisher<? extends T> source)

Method Detail

from

public static <T> BlockingObservable<T> from(org.reactivestreams.Publisher<? extends T> source)

iterator

public java.util.Iterator<T> iterator()

Specified by:

iterator in interface java.lang.Iterable<T>

forEach

public void forEach(Consumer<? super T> action)

firstOption

public Optional<T> firstOption()

first

public T first()

first

public T first(T defaultValue)

lastOption

public Optional<T> lastOption()

last

public T last()

last

public T last(T defaultValue)

single

public T single()

single

public T single(T defaultValue)

mostRecent

public java.lang.Iterable<T> mostRecent(T initialValue)

next

public java.lang.Iterable<T> next()

latest

public java.lang.Iterable<T> latest()

toFuture

public java.util.concurrent.Future<T> toFuture()

run

public void run()

Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super T> subscriber)

Subscribes to the source and calls the Subscriber methods on the current thread.

The unsubscription and backpressure is composed through.

Specified by:

subscribe in interface org.reactivestreams.Publisher<T>

Parameters:

subscriber - the subscriber to forward events and calls to in the current thread

subscribe

public void subscribe()

Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.

subscribe

public void subscribe(Consumer<? super T> onNext)

Subscribes to the source and calls the given action on the current thread and rethrows any exception wrapped into OnErrorNotImplementedException.

Parameters:

onNext - the callback action for each source value

subscribe

public void subscribe(Consumer<? super T> onNext,
                      Consumer<? super java.lang.Throwable> onError)

Subscribes to the source and calls the given actions on the current thread.

Parameters:

onNext - the callback action for each source value

onError - the callback action for an error event

subscribe

public void subscribe(Consumer<? super T> onNext,
                      Consumer<? super java.lang.Throwable> onError,
                      java.lang.Runnable onComplete)

Subscribes to the source and calls the given actions on the current thread.

Parameters:

onNext - the callback action for each source value

onError - the callback action for an error event

onComplete - the callback action for the completion event.