A C D E F G H L M N O R S T U

A

amb(Completable...) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable which terminates as soon as one of the source Completables terminates (normally or with an error) and cancels all other Completables.

amb(Iterable<? extends Completable>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable which terminates as soon as one of the source Completables terminates (normally or with an error) and cancels all other Completables.

ambWith(Completable) - Method in class hu.akarnokd.completable.Completable

Returns a Completable that emits the a terminated event of either this Completable or the other Completable whichever fires first.

await() - Method in class hu.akarnokd.completable.Completable

Subscribes to and awaits the termination of this Completable instance in a blocking manner and rethrows any exception emitted.

await(long, TimeUnit) - Method in class hu.akarnokd.completable.Completable

Subscribes to and awaits the termination of this Completable instance in a blocking manner with a specific timeout and rethrows any exception emitted within the timeout window.

C

call(Completable.CompletableSubscriber) - Method in class hu.akarnokd.completable.internal.CompletableOnSubscribeConcat

call(Completable.CompletableSubscriber) - Method in class hu.akarnokd.completable.internal.CompletableOnSubscribeConcatArray

call(Completable.CompletableSubscriber) - Method in class hu.akarnokd.completable.internal.CompletableOnSubscribeConcatIterable

call(Completable.CompletableSubscriber) - Method in class hu.akarnokd.completable.internal.CompletableOnSubscribeMerge

call(Completable.CompletableSubscriber) - Method in class hu.akarnokd.completable.internal.CompletableOnSubscribeMergeArray

call(Completable.CompletableSubscriber) - Method in class hu.akarnokd.completable.internal.CompletableOnSubscribeMergeDelayErrorArray

call(Completable.CompletableSubscriber) - Method in class hu.akarnokd.completable.internal.CompletableOnSubscribeMergeDelayErrorIterable

call(Completable.CompletableSubscriber) - Method in class hu.akarnokd.completable.internal.CompletableOnSubscribeMergeIterable

call(Completable.CompletableSubscriber) - Method in class hu.akarnokd.completable.internal.CompletableOnSubscribeTimeout

collectErrors(Queue<Throwable>) - Static method in class hu.akarnokd.completable.internal.CompletableOnSubscribeMerge

Collects the Throwables from the queue, adding subsequent Throwables as suppressed to the first Throwable and returns it.

Completable - Class in hu.akarnokd.completable

Represents a deferred computation without any value but only indication for completion or exception.

Completable(Completable.CompletableOnSubscribe) - Constructor for class hu.akarnokd.completable.Completable

Constructs a Completable instance with the given onSubscribe callback.

Completable.CompletableOnSubscribe - Interface in hu.akarnokd.completable

Callback used for building deferred computations that takes a CompletableSubscriber.

Completable.CompletableOperator - Interface in hu.akarnokd.completable

Convenience interface and callback used by the lift operator that given a child CompletableSubscriber, return a parent CompletableSubscriber that does any kind of lifecycle-related transformations.

Completable.CompletableSubscriber - Interface in hu.akarnokd.completable

Represents the subscription API callbacks when subscribing to a Completable instance.

Completable.CompletableTransformer - Interface in hu.akarnokd.completable

Convenience interface and callback used by the compose operator to turn a Completable into another Completable fluently.

CompletableOnSubscribeConcat - Class in hu.akarnokd.completable.internal

CompletableOnSubscribeConcat(Observable<? extends Completable>, int) - Constructor for class hu.akarnokd.completable.internal.CompletableOnSubscribeConcat

CompletableOnSubscribeConcatArray - Class in hu.akarnokd.completable.internal

CompletableOnSubscribeConcatArray(Completable[]) - Constructor for class hu.akarnokd.completable.internal.CompletableOnSubscribeConcatArray

CompletableOnSubscribeConcatIterable - Class in hu.akarnokd.completable.internal

CompletableOnSubscribeConcatIterable(Iterable<? extends Completable>) - Constructor for class hu.akarnokd.completable.internal.CompletableOnSubscribeConcatIterable

CompletableOnSubscribeMerge - Class in hu.akarnokd.completable.internal

CompletableOnSubscribeMerge(Observable<? extends Completable>, int, boolean) - Constructor for class hu.akarnokd.completable.internal.CompletableOnSubscribeMerge

CompletableOnSubscribeMergeArray - Class in hu.akarnokd.completable.internal

CompletableOnSubscribeMergeArray(Completable[]) - Constructor for class hu.akarnokd.completable.internal.CompletableOnSubscribeMergeArray

CompletableOnSubscribeMergeDelayErrorArray - Class in hu.akarnokd.completable.internal

CompletableOnSubscribeMergeDelayErrorArray(Completable[]) - Constructor for class hu.akarnokd.completable.internal.CompletableOnSubscribeMergeDelayErrorArray

CompletableOnSubscribeMergeDelayErrorIterable - Class in hu.akarnokd.completable.internal

CompletableOnSubscribeMergeDelayErrorIterable(Iterable<? extends Completable>) - Constructor for class hu.akarnokd.completable.internal.CompletableOnSubscribeMergeDelayErrorIterable

CompletableOnSubscribeMergeIterable - Class in hu.akarnokd.completable.internal

CompletableOnSubscribeMergeIterable(Iterable<? extends Completable>) - Constructor for class hu.akarnokd.completable.internal.CompletableOnSubscribeMergeIterable

CompletableOnSubscribeTimeout - Class in hu.akarnokd.completable.internal

CompletableOnSubscribeTimeout(Completable, long, TimeUnit, Scheduler, Completable) - Constructor for class hu.akarnokd.completable.internal.CompletableOnSubscribeTimeout

complete() - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that completes immediately when subscribed to.

compose(Completable.CompletableTransformer) - Method in class hu.akarnokd.completable.Completable

Calls the given transformer function with this instance and returns the function's resulting Completable.

concat(Completable...) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable which completes only when all sources complete, one after another.

concat(Iterable<? extends Completable>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable which completes only when all sources complete, one after another.

concat(Observable<? extends Completable>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable which completes only when all sources complete, one after another.

concat(Observable<? extends Completable>, int) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable which completes only when all sources complete, one after another.

concatWith(Completable) - Method in class hu.akarnokd.completable.Completable

Concatenates this Completable with another Completable.

create(Completable.CompletableOnSubscribe) - Static method in class hu.akarnokd.completable.Completable

Constructs a Completable instance by wrapping the given onSubscribe callback.

D

defer(Func0<? extends Completable>) - Static method in class hu.akarnokd.completable.Completable

Defers the subscription to a Completable instance returned by a supplier.

delay(long, TimeUnit) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which delays the emission of the completion event by the given time.

delay(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which delays the emission of the completion event by the given time while running on the specified scheduler.

delay(long, TimeUnit, Scheduler, boolean) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which delays the emission of the completion event, and optionally the error as well, by the given time while running on the specified scheduler.

doOnComplete(Action0) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which calls the given onComplete callback if this Completable completes.

doOnError(Action1<? super Throwable>) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which calls the given onError callback if this Completable emits an error.

doOnLifecycle(Action1<? super Subscription>, Action1<? super Throwable>, Action0, Action0, Action0) - Method in class hu.akarnokd.completable.Completable

Returns a Completable instance that calls the various callbacks on the specific lifecycle events.

doOnSubscribe(Action1<? super Subscription>) - Method in class hu.akarnokd.completable.Completable

Returns a Completable instance that calls the given onSubscribe callback with the disposable that child subscribers receive on subscription.

doOnTerminate(Action0) - Method in class hu.akarnokd.completable.Completable

Returns a Completable instance that calls the given onTerminate callback just before this Completable completes normally or with an exception

doOnUnsubscribe(Action0) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which calls the giveon onUnsubscribe callback if the child subscriber cancels the subscription.

E

endWith(Completable) - Method in class hu.akarnokd.completable.Completable

Returns a completable that first runs this Completable and then the other completable.

endWith(Observable<T>) - Method in class hu.akarnokd.completable.Completable

Returns an Observable that first runs this Completable instance and resumes with the given next Observable.

error(Func0<? extends Throwable>) - Static method in class hu.akarnokd.completable.Completable

Creates a Completable which calls the given error supplier for each subscriber and emits its returned Throwable.

error(Throwable) - Static method in class hu.akarnokd.completable.Completable

Creates a Completable instance that emits the given Throwable exception to subscribers.

F

finallyDo(Action0) - Method in class hu.akarnokd.completable.Completable

Returns a Completable instace that calls the given onAfterComplete callback after this Completable completes normally.

fromAction(Action0) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that runs the given Action0 for each subscriber and emits either an unchecked exception or simply completes.

fromCallable(Callable<?>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable which when subscribed, executes the callable function, ignores its normal result and emits onError or onCompleted only.

fromFuture(Future<?>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that reacts to the termination of the given Future in a blocking fashion.

fromObservable(Observable<?>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that subscribes to the given flowable, ignores all values and emits only the terminal event.

fromSingle(Single<?>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that when subscribed to, subscribes to the Single instance and emits a completion event if the single emits onSuccess or forwards any onError events.

G

get() - Method in class hu.akarnokd.completable.Completable

Subscribes to this Completable instance and blocks until it terminates, then returns null or the emitted exception if any.

get(long, TimeUnit) - Method in class hu.akarnokd.completable.Completable

Subscribes to this Completable instance and blocks until it terminates or the specified timeout ellapses, then returns null for normal termination or the emitted exception if any.

H

hu.akarnokd.completable - package hu.akarnokd.completable

hu.akarnokd.completable.internal - package hu.akarnokd.completable.internal

L

lift(Completable.CompletableOperator) - Method in class hu.akarnokd.completable.Completable

Lifts a CompletableSubscriber transformation into the chain of Completables.

M

merge(Completable...) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that subscribes to all sources at once and completes only when all source Completables complete or one of them emits an error.

merge(Iterable<? extends Completable>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that subscribes to all sources at once and completes only when all source Completables complete or one of them emits an error.

merge(Observable<? extends Completable>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that subscribes to all sources at once and completes only when all source Completables complete or one of them emits an error.

merge(Observable<? extends Completable>, int) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that keeps subscriptions to a limited number of sources at once and completes only when all source Completables complete or one of them emits an error.

merge0(Observable<? extends Completable>, int, boolean) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that keeps subscriptions to a limited number of sources at once and completes only when all source Completables terminate in one way or another, combining any exceptions thrown by either the sources Observable or the inner Completable instances.

mergeDelayError(Completable...) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable that subscribes to all Completables in the source array and delays any error emitted by either the sources observable or any of the inner Completables until all of them terminate in a way or another.

mergeDelayError(Iterable<? extends Completable>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable that subscribes to all Completables in the source sequence and delays any error emitted by either the sources observable or any of the inner Completables until all of them terminate in a way or another.

mergeDelayError(Observable<? extends Completable>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable that subscribes to all Completables in the source sequence and delays any error emitted by either the sources observable or any of the inner Completables until all of them terminate in a way or another.

mergeDelayError(Observable<? extends Completable>, int) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable that subscribes to a limited number of inner Completables at once in the source sequence and delays any error emitted by either the sources observable or any of the inner Completables until all of them terminate in a way or another.

mergeWith(Completable) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which subscribes to this and the other Completable and completes when both of them complete or one emits an error.

N

never() - Static method in class hu.akarnokd.completable.Completable

Returns a Completable that never calls onError or onComplete.

O

observeOn(Scheduler) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which emits the terminal events from the thread of the specified scheduler.

onCompleted() - Method in interface hu.akarnokd.completable.Completable.CompletableSubscriber

Called once the deferred computation completes normally.

onError(Throwable) - Method in interface hu.akarnokd.completable.Completable.CompletableSubscriber

Called once if the deferred computation 'throws' an exception.

onErrorComplete() - Method in class hu.akarnokd.completable.Completable

Returns a Completable instance that if this Completable emits an error, it will emit an onComplete and swallow the throwable.

onErrorComplete(Func1<? super Throwable, Boolean>) - Method in class hu.akarnokd.completable.Completable

Returns a Completable instance that if this Completable emits an error and the predicate returns true, it will emit an onComplete and swallow the throwable.

onErrorResumeNext(Func1<? super Throwable, ? extends Completable>) - Method in class hu.akarnokd.completable.Completable

Returns a Completable instance that when encounters an error from this Completable, calls the specified mapper function that returns another Completable instance for it and resumes the execution with it.

onSubscribe(Subscription) - Method in interface hu.akarnokd.completable.Completable.CompletableSubscriber

Called once by the Completable to set a Subscription on this instance which then can be used to cancel the subscription at any time.

R

repeat() - Method in class hu.akarnokd.completable.Completable

Returns a Completable that repeatedly subscribes to this Completable until cancelled.

repeat(long) - Method in class hu.akarnokd.completable.Completable

Returns a Completable that subscribes repeatedly at most the given times to this Completable.

repeatWhen(Func1<? super Observable<? extends Void>, ? extends Observable<?>>) - Method in class hu.akarnokd.completable.Completable

Returns a Completable instance that repeats when the Publisher returned by the handler emits an item or completes when this Publisher emits a completed event.

retry() - Method in class hu.akarnokd.completable.Completable

Returns a Completable that retries this Completable as long as it emits an onError event.

retry(Func2<Integer, Throwable, Boolean>) - Method in class hu.akarnokd.completable.Completable

Returns a Completable that retries this Completable in case of an error as long as the predicate returns true.

retry(long) - Method in class hu.akarnokd.completable.Completable

Returns a Completable that when this Completable emits an error, retries at most the given number of times before giving up and emitting the last error.

retryWhen(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>>) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which given a Publisher and when this Completable emits an error, delivers that error through an Observable and the Publisher should return a value indicating a retry in response or a terminal event indicating a termination.

S

startWith(Completable) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which first runs the other Completable then this completable if the other completed normally.

startWith(Observable<T>) - Method in class hu.akarnokd.completable.Completable

Returns an Observable which first delivers the events of the other Observable then runs this Completable.

subscribe() - Method in class hu.akarnokd.completable.Completable

Subscribes to this Completable and returns a Subscription which can be used to cancel the subscription.

subscribe(Action0) - Method in class hu.akarnokd.completable.Completable

Subscribes to this Completable and calls the given Action0 when this Completable completes normally.

subscribe(Action1<? super Throwable>, Action0) - Method in class hu.akarnokd.completable.Completable

Subscribes to this Completable and calls back either the onError or onComplete functions.

subscribe(Completable.CompletableSubscriber) - Method in class hu.akarnokd.completable.Completable

Subscribes the given CompletableSubscriber to this Completable instance.

subscribe(Subscriber<T>) - Method in class hu.akarnokd.completable.Completable

Subscribes a reactive-streams Subscriber to this Completable instance which will receive only an onError or onComplete event.

subscribeOn(Scheduler) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which subscribes the child subscriber on the specified scheduler, making sure the subscription side-effects happen on that specific thread of the scheduler.

T

timeout(long, TimeUnit) - Method in class hu.akarnokd.completable.Completable

Returns a Completable that runs this Completable and emits a TimeoutException in case this Completable doesn't complete within the given time.

timeout(long, TimeUnit, Completable) - Method in class hu.akarnokd.completable.Completable

Returns a Completable that runs this Completable and switches to the other Completable in case this Completable doesn't complete within the given time.

timeout(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.completable.Completable

Returns a Completable that runs this Completable and emits a TimeoutException in case this Completable doesn't complete within the given time while "waiting" on the specified Scheduler.

timeout(long, TimeUnit, Scheduler, Completable) - Method in class hu.akarnokd.completable.Completable

Returns a Completable that runs this Completable and switches to the other Completable in case this Completable doesn't complete within the given time while "waiting" on the specified scheduler.

timeout0(long, TimeUnit, Scheduler, Completable) - Method in class hu.akarnokd.completable.Completable

Returns a Completable that runs this Completable and optionally switches to the other Completable in case this Completable doesn't complete within the given time while "waiting" on the specified scheduler.

timer(long, TimeUnit) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that fires its onComplete event after the given delay ellapsed.

timer(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance that fires its onComplete event after the given delay ellapsed by using the supplied scheduler.

to(Func1<? super Completable, U>) - Method in class hu.akarnokd.completable.Completable

Allows fluent conversion to another type via a function callback.

toObservable() - Method in class hu.akarnokd.completable.Completable

Returns an Observable which when subscribed to subscribes to this Completable and relays the terminal events to the subscriber.

toSingle(Func0<? extends T>) - Method in class hu.akarnokd.completable.Completable

Convers this Completable into a Single which when this Completable completes normally, calls the given supplier and emits its returned value through onSuccess.

toSingleDefault(T) - Method in class hu.akarnokd.completable.Completable

Convers this Completable into a Single which when this Completable completes normally, emits the given value through onSuccess.

U

unsubscribeOn(Scheduler) - Method in class hu.akarnokd.completable.Completable

Returns a Completable which makes sure when a subscriber cancels the subscription, the dispose is called on the specified scheduler

using(Func0<R>, Func1<? super R, ? extends Completable>, Action1<? super R>) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance which manages a resource along with a custom Completable instance while the subscription is active.

using(Func0<R>, Func1<? super R, ? extends Completable>, Action1<? super R>, boolean) - Static method in class hu.akarnokd.completable.Completable

Returns a Completable instance which manages a resource along with a custom Completable instance while the subscription is active and performs eager or lazy resource disposition.

A C D E F G H L M N O R S T U