T first()
Returns the first item emitted by this BlockingObservable, or throws NoSuchElementException if it emits no items.
T first(Func1<? super T,java.lang.Boolean> predicate)
Returns the first item emitted by this BlockingObservable that matches a predicate, or throws NoSuchElementException if it emits no such item.
T firstOrDefault(T defaultValue)
Returns the first item emitted by this BlockingObservable, or a default value if it emits no items.
T firstOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate)
Returns the first item emitted by this BlockingObservable that matches a predicate, or a default value if it emits no such items.
void forEach(Action1<? super T> onNext)
Invokes a method on each item emitted by this BlockingObservable and blocks until the Observable completes.
static <T> BlockingObservable<T> from(Observable<? extends T> o)
Converts an
Observable
into a
BlockingObservable
.
java.util.Iterator<T> getIterator()
Returns an Iterator that iterates over all items emitted by this BlockingObservable.
T last()
Returns the last item emitted by this BlockingObservable, or throws NoSuchElementException if this BlockingObservable emits no items.
T last(Func1<? super T,java.lang.Boolean> predicate)
Returns the last item emitted by this BlockingObservable that matches a predicate, or throws NoSuchElementException if it emits no such items.
T lastOrDefault(T defaultValue)
Returns the last item emitted by this BlockingObservable, or a default value if it emits no items.
T lastOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate)
Returns the last item emitted by this BlockingObservable that matches a predicate, or a default value if it emits no such items.
java.lang.Iterable<T> latest()
Returns an Iterable that returns the latest item emitted by this BlockingObservable, waiting if necessary for one to become available.
java.lang.Iterable<T> mostRecent(T initialValue)
Returns an Iterable that always returns the item most recently emitted by this BlockingObservable.
java.lang.Iterable<T> next()
Returns an Iterable that blocks until this BlockingObservable emits another item, then returns that item.
T single()
If this BlockingObservable completes after emitting a single item, return that item, otherwise throw a NoSuchElementException.
T single(Func1<? super T,java.lang.Boolean> predicate)
If this BlockingObservable completes after emitting a single item that matches a given predicate, return that item, otherwise throw a NoSuchElementException.
T singleOrDefault(T defaultValue)
If this BlockingObservable completes after emitting a single item, return that item; if it emits more than one item, throw an IllegalArgumentException; if it emits no items, return a default value.
T singleOrDefault(T defaultValue, Func1<? super T,java.lang.Boolean> predicate)
If this BlockingObservable completes after emitting a single item that matches a predicate, return that item; if it emits more than one such item, throw an IllegalArgumentException; if it emits no items, return a default value.
void subscribe()
Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
void subscribe(Action1<? 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(Action1<? super T> onNext, Action1<? super java.lang.Throwable> onError)
Subscribes to the source and calls the given actions on the current thread.
void subscribe(Action1<? super T> onNext, Action1<? super java.lang.Throwable> onError, Action0 onCompleted)
Subscribes to the source and calls the given actions on the current thread.
void subscribe(Observer<? super T> observer)
Subscribes to the source and calls back the Observer methods on the current thread.
void subscribe(Subscriber<? super T> subscriber)
Subscribes to the source and calls the Subscriber methods on the current thread.
java.util.concurrent.Future<T> toFuture()
Returns a Future representing the single value emitted by this BlockingObservable.
java.lang.Iterable<T> toIterable()
Converts this BlockingObservable into an Iterable.
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4