- of(T) - Static method in interface com.diffplug.common.rx.CasBox
-
Returns a CasBox around the given value.
- of(T) - Static method in interface com.diffplug.common.rx.LockBox
-
Creates a `LockBox` containing the given value, which uses itself as the lock.
- of(T, Object) - Static method in interface com.diffplug.common.rx.LockBox
-
Creates a `LockBox` containing the given value, and using the given object as the lock.
- of(T) - Static method in interface com.diffplug.common.rx.RxBox
-
Creates an `RxBox` with the given initial value.
- of(T) - Static method in interface com.diffplug.common.rx.RxLockBox
-
Creates an `RxLockBox` containing the given value, which uses itself as the lock.
- of(T, Object) - Static method in interface com.diffplug.common.rx.RxLockBox
-
Creates an `RxLockBox` containing the given value, which uses `lock` as the lock.
- of(ImmutableList<T>) - Static method in class com.diffplug.common.rx.RxOrderedSet
-
Creates an RxList with the given initial value.
- of(ImmutableList<T>, RxOrderedSet.OnDuplicate) - Static method in class com.diffplug.common.rx.RxOrderedSet
-
Creates an RxList with the given initial value.
- ofEmpty() - Static method in class com.diffplug.common.rx.RxOrderedSet
-
Creates an RxList with an initially empty value.
- ofEmpty(RxOrderedSet.OnDuplicate) - Static method in class com.diffplug.common.rx.RxOrderedSet
-
Creates an RxList with an initially empty value.
- on(Collection<?>) - Static method in class com.diffplug.common.rx.OrderedLock
-
Creates an OrderedLock for the given collection of locks.
- on(Object...) - Static method in class com.diffplug.common.rx.OrderedLock
-
Creates an OrderedLock for the given array of locks.
- onComplete() - Method in class com.diffplug.common.rx.RxListener
-
- onError(Throwable) - Method in class com.diffplug.common.rx.RxListener
-
- onErrorDontLog(Throwable) - Method in class com.diffplug.common.rx.RxListener
-
- onFailure(Consumer<Throwable>) - Static method in class com.diffplug.common.rx.Rx
-
Creates an Rx instance which will call the given consumer whenever the followed stream
or future completes with an error.
- onFailure(Throwable) - Method in class com.diffplug.common.rx.RxListener
-
- onNext(T) - Method in class com.diffplug.common.rx.RxListener
-
- onSubscribe(Disposable) - Method in class com.diffplug.common.rx.RxListener
-
- onSuccess(T) - Method in class com.diffplug.common.rx.RxListener
-
- onTerminate(Consumer<Optional<Throwable>>) - Static method in class com.diffplug.common.rx.Rx
-
Creates an Rx instance which will call the given consumer whenever the followed stream
or future completes, whether with an error or not.
- onTerminateLogError(Consumer<Optional<Throwable>>) - Static method in class com.diffplug.common.rx.Rx
-
Creates an Rx instance which will call the given consumer whenever the followed stream
or future completes, whether with an error or not, and the error (if present) will be logged.
- onValue(Consumer<T>) - Static method in class com.diffplug.common.rx.Rx
-
Creates an Rx instance which will call the given consumer whenever a value is received.
- onValueOnFailure(Consumer<T>, Consumer<Throwable>) - Static method in class com.diffplug.common.rx.Rx
-
Creates an Rx instance which will call onValue whenever a value is received,
and onFailure if the stream or future completes with an error.
- onValueOnTerminate(Consumer<T>, Consumer<Optional<Throwable>>) - Static method in class com.diffplug.common.rx.Rx
-
Creates an Rx instance which will call onValue whenever a value is received,
is received, and onTerminate when the future or observable completes, whether with an error or not.
- onValueOnTerminateLogError(Consumer<T>, Consumer<Optional<Throwable>>) - Static method in class com.diffplug.common.rx.Rx
-
Creates an Rx instance which will call the given consumer whenever the followed stream
or future completes, whether with an error or not, and the error (if present) will automatically be logged.
- optEitherFrom(Either<Optional<T>, Optional<U>>) - Static method in class com.diffplug.common.rx.MultiSelectModel
-
Creates an Optional from an Either.
- OrderedLock - Class in com.diffplug.common.rx
-
All code which takes locks using this code is guaranteed to do so
in the same order, guaranteeing there won't be a deadlock.