Skip navigation links

com.diffplug.durian:durian-rx:3.1.0-SNAPSHOT by DiffPlug

A B C D E F G H I L M N O R S T V W 

A

alreadyDisposed() - Static method in interface com.diffplug.common.rx.Chit
Returns a Chit which has already been disposed.
asObservable() - Method in class com.diffplug.common.rx.ForwardingBox.Rx
 
asObservable() - Method in class com.diffplug.common.rx.ForwardingBox.RxLock
 
asObservable() - Method in interface com.diffplug.common.rx.IObservable
 

B

Breaker<T> - Class in com.diffplug.common.rx
A mechanism for "turning off" an existing `RxBox`, much like a a circuit breaker.

C

callbackOn(Executor) - Static method in class com.diffplug.common.rx.Rx
Mechanism for specifying a specific Executor.
callbackOn(Executor, Scheduler) - Static method in class com.diffplug.common.rx.Rx
Mechanism for specifying a specific Executor (for ListenableFuture) and Scheduler (for Observable).
Cas(CasBox<T>) - Constructor for class com.diffplug.common.rx.ForwardingBox.Cas
 
CasBox<T> - Interface in com.diffplug.common.rx
CasBox is a lock-free and race-condition-free mechanism for updating a value.
Chit - Interface in com.diffplug.common.rx
Makes it possible to receive a notification when a resource is disposed.
Chit.Settable - Class in com.diffplug.common.rx
The standard implementation of DisposableEar.
clicked - Variable in class com.diffplug.common.rx.MultiSelectModel
 
clicked() - Method in class com.diffplug.common.rx.MultiSelectModel
A publish subject which responds to clicks.
com.diffplug.common.rx - package com.diffplug.common.rx
DurianRx unifies RxJava's [Observable](http://reactivex.io/documentation/observable.html) with Guava's [ListenableFuture](https://code.google.com/p/guava-libraries/wiki/ListenableFutureExplained).
combineLatest(RxGetter<? extends T1>, RxGetter<? extends T2>, BiFunction<? super T1, ? super T2, ? extends R>) - Static method in interface com.diffplug.common.rx.RxGetter
Creates an `RxGetter` which combines two `RxGetter`s using the `BiFunction combine`.
compareAndSet(T, T) - Method in interface com.diffplug.common.rx.CasBox
The compare and set method which this box is capable of using.
compareAndSet(T, T) - Method in class com.diffplug.common.rx.ForwardingBox.Cas
 
createClosed(RxBox<T>) - Static method in class com.diffplug.common.rx.Breaker
Creates a `Breaker` which is initially closed.
createOpen(RxBox<T>) - Static method in class com.diffplug.common.rx.Breaker
Creates a `Breaker` which is initially open.

D

delegate - Variable in class com.diffplug.common.rx.Breaker
 
delegate - Variable in class com.diffplug.common.rx.ForwardingBox
 
dispose() - Method in class com.diffplug.common.rx.Chit.Settable
 

E

enforce(Function<? super T, ? extends T>) - Method in interface com.diffplug.common.rx.RxBox
Provides a mechanism for enforcing an invariant on an existing `RxBox`.
enforce(Function<? super T, ? extends T>) - Method in interface com.diffplug.common.rx.RxLockBox
 
execute(Runnable) - Method in class com.diffplug.common.rx.GuardedExecutor
 
executor() - Method in class com.diffplug.common.rx.RxExecutor
 

F

fire() - Method in class com.diffplug.common.rx.RateProbe
Fires the rate probe, and returns the elapsed time in nanoseconds since the last call.
ForwardingBox<T,BoxType extends Box<T>> - Class in com.diffplug.common.rx
Utility class for wrapping one kind of box with another.
ForwardingBox(BoxType) - Constructor for class com.diffplug.common.rx.ForwardingBox
 
ForwardingBox.Cas<T> - Class in com.diffplug.common.rx
 
ForwardingBox.Lock<T> - Class in com.diffplug.common.rx
 
ForwardingBox.Rx<T> - Class in com.diffplug.common.rx
 
ForwardingBox.RxLock<T> - Class in com.diffplug.common.rx
 
from(RxGetter<T>, Consumer<T>) - Static method in interface com.diffplug.common.rx.RxBox
Creates an `RxBox` which implements the "getter" part with `RxGetter`, and the setter part with `Consumer`.
from(Observable<T>, T) - Static method in interface com.diffplug.common.rx.RxGetter
Creates an `RxGetter` from the given `Observable` and `initialValue`, appropriate for observables which emit values on a single thread.
fromVolatile(Observable<T>, T) - Static method in interface com.diffplug.common.rx.RxGetter
Creates an `RxGetter` from the given `Observable` and `initialValue`, appropriate for observables which emit values on multiple threads.

G

get() - Method in class com.diffplug.common.rx.Breaker
 
get() - Method in class com.diffplug.common.rx.ForwardingBox
 
getAndSet(T) - Method in interface com.diffplug.common.rx.CasBox
Gets the current value, and sets it with a new one.
getAndSet(T) - Method in class com.diffplug.common.rx.ForwardingBox.Cas
 
getDelegateRxExecutor() - Method in class com.diffplug.common.rx.GuardedExecutor
The underlying executor which is being delegated to.
getDuplicatePolicy() - Method in class com.diffplug.common.rx.RxOrderedSet
Returns the duplicate policy for this RxList.
getGuard() - Method in class com.diffplug.common.rx.GuardedExecutor
The element on which all executions and subscriptions are guarded.
getMouseOver() - Method in class com.diffplug.common.rx.MultiSelectModel.Trumped
 
getRxExecutor() - Method in interface com.diffplug.common.rx.RxExecutor.Has
 
getSelection() - Method in class com.diffplug.common.rx.MultiSelectModel.Trumped
 
getTracingPolicy() - Static method in class com.diffplug.common.rx.Rx
Returns the global tracing policy.
guard(Runnable) - Method in interface com.diffplug.common.rx.Chit
Wraps the runnable such that it will only run iff the disposable has not been disposed, according to Chit.isDisposed().
GuardedExecutor - Class in com.diffplug.common.rx
GuardedExecutor is an Executor and RxSubscriber which promises to cancel its subscriptions and stop executing tasks once its GuardedExecutor.getGuard() has been disposed.
GuardedExecutor(RxExecutor, Chit) - Constructor for class com.diffplug.common.rx.GuardedExecutor
 

H

hook(Object, RxListener<T>) - Method in interface com.diffplug.common.rx.RxTracingPolicy
Given an observable, and an Rx which is about to be subscribed to this observable, return a (possibly instrumented) `Rx`.
hook(Object, RxListener<T>) - Method in class com.diffplug.common.rx.RxTracingPolicy.LogSubscriptionTrace
 

I

IObservable<T> - Interface in com.diffplug.common.rx
An object which can be supplied in an Observable form.
isCtrl - Variable in class com.diffplug.common.rx.MultiSelectModel
 
isCtrl() - Method in class com.diffplug.common.rx.MultiSelectModel
 
isCtrl(boolean) - Method in class com.diffplug.common.rx.MultiSelectModel
 
isDisposed() - Method in interface com.diffplug.common.rx.Chit
Returns whether the resource is disposed.
isDisposed() - Method in class com.diffplug.common.rx.Chit.Settable
 
isLogging() - Method in class com.diffplug.common.rx.RxListener
Returns true iff the given Rx is a logging Rx.

L

Lock(LockBox<T>) - Constructor for class com.diffplug.common.rx.ForwardingBox.Lock
 
lock() - Method in class com.diffplug.common.rx.ForwardingBox.Lock
 
lock() - Method in class com.diffplug.common.rx.ForwardingBox.RxLock
 
lock() - Method in interface com.diffplug.common.rx.LockBox
The lock which is used by this LockBox's method.
LockBox<T> - Interface in com.diffplug.common.rx
LockBox is a box where every call to LockBox.modify(Function) happens within a synchronized block.
LogSubscriptionTrace() - Constructor for class com.diffplug.common.rx.RxTracingPolicy.LogSubscriptionTrace
 

M

map(Converter<T, R>) - Method in interface com.diffplug.common.rx.CasBox
 
map(Converter<T, R>) - Method in interface com.diffplug.common.rx.LockBox
Maps this LockBox to a new value which will have the same lock as the original lock, since there's still only one piece of state.
map(Converter<T, R>) - Method in interface com.diffplug.common.rx.RxBox
Maps one `RxBox` to another `RxBox`.
map(Function<? super T, ? extends R>) - Method in interface com.diffplug.common.rx.RxGetter
Maps an `RxGetter` to a new `RxGetter` by applying the `mapper` function to all of its values.
map(Converter<T, R>) - Method in interface com.diffplug.common.rx.RxLockBox
RxLockBox must map to another kind of LockBox.
merge(IObservable<? extends T>...) - Static method in class com.diffplug.common.rx.Rx
Merges a bunch of IObservables into a single Observable containing the most-recent value.
modify(Function<? super T, ? extends T>) - Method in interface com.diffplug.common.rx.CasBox
Applies the given mutator function to this box, which may require calling the function more than once, so make sure it's pure! The function is called using the box's current input, and compareAndSet is used to ensure that the input does not change.
modify(Function<? super T, ? extends T>) - Method in interface com.diffplug.common.rx.LockBox
 
mouseOver - Variable in class com.diffplug.common.rx.MultiSelectModel
 
mouseOver() - Method in class com.diffplug.common.rx.MultiSelectModel
Returns the mouseOver selection.
MultiSelectModel<T> - Class in com.diffplug.common.rx
Manages a selection based on a a MouseOver / Selection combination.
MultiSelectModel(RxBox<Optional<T>>, RxBox<ImmutableSet<T>>, PublishSubject<T>) - Constructor for class com.diffplug.common.rx.MultiSelectModel
Creates a MultiSelectModel from the given SelectionModels.
MultiSelectModel() - Constructor for class com.diffplug.common.rx.MultiSelectModel
Creates an MultiSelectModel from scratch.
MultiSelectModel.Trumped<T,U> - Class in com.diffplug.common.rx
A MultiSelectModel-ish which represents two trumped selections.
mutate(Consumer<List<T>>) - Method in class com.diffplug.common.rx.RxOrderedSet
Mutates this set.

N

NONE - Static variable in interface com.diffplug.common.rx.RxTracingPolicy
An `RxTracingPolicy` which performs no tracing, and has very low overhead.

O

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.

R

rateHzOver(long, TimeUnit) - Method in class com.diffplug.common.rx.RateProbe
Returns the average rate in hertz over the specified time period.
rateHzOverNSamples(int) - Method in class com.diffplug.common.rx.RateProbe
Returns the average rate in hertz over the last n samples.
RateProbe - Class in com.diffplug.common.rx
A probe for inspecting rates in reactive systems.
RateProbe() - Constructor for class com.diffplug.common.rx.RateProbe
 
readOnly() - Method in interface com.diffplug.common.rx.RxBox
Returns a read-only version of this `RxBox`.
runWhenDisposed(Runnable) - Method in interface com.diffplug.common.rx.Chit
Adds a listener which will run when the given element is disposed.
runWhenDisposed(Runnable) - Method in class com.diffplug.common.rx.Chit.Settable
 
Rx(RxBox<T>) - Constructor for class com.diffplug.common.rx.ForwardingBox.Rx
 
Rx - Class in com.diffplug.common.rx
Unifies the listener models of RxJava's Observable with Guava's ListenableFuture , and also adds tracing capabilities.
RxBox<T> - Interface in com.diffplug.common.rx
RxGetter and Box combined in one: a value you can set, get, and subscribe to.
RxExecutor - Class in com.diffplug.common.rx
This class holds an instance of Executor (for ListenableFuture) and Scheduler (for Observable).
RxExecutor.Has - Interface in com.diffplug.common.rx
Marker interface which allows an Executor to specify its own Scheduler.
RxGetter<T> - Interface in com.diffplug.common.rx
Represents a value which can be accessed through a traditional `get()` method or by listening to its Observable.
RxJavaCompat - Class in com.diffplug.common.rx
 
RxJavaCompat() - Constructor for class com.diffplug.common.rx.RxJavaCompat
 
RxListener<T> - Class in com.diffplug.common.rx
 
RxLock(RxLockBox<T>) - Constructor for class com.diffplug.common.rx.ForwardingBox.RxLock
 
RxLockBox<T> - Interface in com.diffplug.common.rx
RxBox and LockBox in one.
RxOrderedSet<T> - Class in com.diffplug.common.rx
RxBox<ImmutableList<T>> which promises to exclude duplicates.
RxOrderedSet(ImmutableList<T>, RxOrderedSet.OnDuplicate) - Constructor for class com.diffplug.common.rx.RxOrderedSet
Initally holds the given collection.
RxOrderedSet.OnDuplicate - Enum in com.diffplug.common.rx
Policies for disallowing duplicates.
RxSubscriber - Interface in com.diffplug.common.rx
An object which can subscribe observables to RxListener listeners.
RxTracingPolicy - Interface in com.diffplug.common.rx
Plugin which gets notified of every call to Rx.subscribe, allowing various kinds of tracing.
RxTracingPolicy.LogSubscriptionTrace - Class in com.diffplug.common.rx
An RxTracingPolicy which logs the stack trace of every subscription, so that it can decorate any exceptions with the stack trace at the time they were subscribed.

S

sameThreadExecutor() - Static method in class com.diffplug.common.rx.Rx
 
scheduler() - Method in class com.diffplug.common.rx.RxExecutor
 
selection - Variable in class com.diffplug.common.rx.MultiSelectModel
 
selection() - Method in class com.diffplug.common.rx.MultiSelectModel
Returns the current selection.
set(T) - Method in class com.diffplug.common.rx.Breaker
 
set(T) - Method in class com.diffplug.common.rx.ForwardingBox
 
set(ImmutableList<T>) - Method in class com.diffplug.common.rx.RxOrderedSet
Sets the selection.
setClosed(boolean) - Method in class com.diffplug.common.rx.Breaker
Sets that this breaker is closed or open.
settable() - Static method in interface com.diffplug.common.rx.Chit
Creates a Settable Disposable ear.
shouldLog - Static variable in class com.diffplug.common.rx.RxTracingPolicy.LogSubscriptionTrace
The BiPredicate which determines which subscriptions should be logged.
subscribe(Observable<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.GuardedExecutor
 
subscribe(ListenableFuture<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.GuardedExecutor
 
subscribe(CompletionStage<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.GuardedExecutor
 
subscribe(Observer<? super T>) - Method in interface com.diffplug.common.rx.IObservable
 
subscribe(Observable<? extends T>, RxListener<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribe(Observable<? extends T>, Consumer<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribe(IObservable<? extends T>, RxListener<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribe(IObservable<? extends T>, Consumer<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribe(ListenableFuture<? extends T>, RxListener<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribe(ListenableFuture<? extends T>, Consumer<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribe(CompletionStage<? extends T>, RxListener<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribe(CompletionStage<? extends T>, Consumer<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribe(Observable<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.RxExecutor
 
subscribe(ListenableFuture<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.RxExecutor
 
subscribe(CompletionStage<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.RxExecutor
 
subscribe(Observable<? extends T>, RxListener<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
Subscribes the given listener to the given observable.
subscribe(ListenableFuture<? extends T>, RxListener<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
Subscribes the given listener to the given Guava ListenableFuture.
subscribe(CompletionStage<? extends T>, RxListener<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
Subscribes the given listener to the given Java 8 CompletableFuture.
subscribe(Observable<? extends T>, Consumer<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
 
subscribe(IObservable<? extends T>, RxListener<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
 
subscribe(IObservable<? extends T>, Consumer<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
 
subscribe(ListenableFuture<? extends T>, Consumer<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
 
subscribe(CompletionStage<? extends T>, Consumer<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
 
subscribeDisposable(Observable<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.GuardedExecutor
 
subscribeDisposable(ListenableFuture<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.GuardedExecutor
 
subscribeDisposable(CompletionStage<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.GuardedExecutor
 
subscribeDisposable(Observable<? extends T>, RxListener<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribeDisposable(Observable<? extends T>, Consumer<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribeDisposable(IObservable<? extends T>, RxListener<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribeDisposable(IObservable<? extends T>, Consumer<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribeDisposable(ListenableFuture<? extends T>, RxListener<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribeDisposable(ListenableFuture<? extends T>, Consumer<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribeDisposable(CompletionStage<? extends T>, RxListener<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribeDisposable(CompletionStage<? extends T>, Consumer<T>) - Static method in class com.diffplug.common.rx.Rx
 
subscribeDisposable(Observable<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.RxExecutor
 
subscribeDisposable(ListenableFuture<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.RxExecutor
 
subscribeDisposable(CompletionStage<? extends T>, RxListener<T>) - Method in class com.diffplug.common.rx.RxExecutor
 
subscribeDisposable(Observable<? extends T>, RxListener<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
Subscribes the given listener to the given observable.
subscribeDisposable(ListenableFuture<? extends T>, RxListener<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
Subscribes the given listener to the given Guava ListenableFuture.
subscribeDisposable(CompletionStage<? extends T>, RxListener<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
Subscribes the given listener to the given Java 8 CompletableFuture.
subscribeDisposable(Observable<? extends T>, Consumer<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
 
subscribeDisposable(IObservable<? extends T>, RxListener<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
 
subscribeDisposable(IObservable<? extends T>, Consumer<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
 
subscribeDisposable(ListenableFuture<? extends T>, Consumer<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
 
subscribeDisposable(CompletionStage<? extends T>, Consumer<T>) - Method in interface com.diffplug.common.rx.RxSubscriber
 
sync(RxBox<T>, RxBox<T>) - Static method in class com.diffplug.common.rx.Rx
Reliable way to sync two RxBox to each other.
sync(RxSubscriber, RxBox<T>, RxBox<T>) - Static method in class com.diffplug.common.rx.Rx
Reliable way to sync two RxBox to each other, using the given RxSubscriber to listen for changes

T

takeAndGet(Supplier<T>) - Method in class com.diffplug.common.rx.OrderedLock
Takes the locks in a globally consistent order, then calls the given supplier and returns its value.
takeAndRun(Runnable) - Method in class com.diffplug.common.rx.OrderedLock
Takes the locks in a globally consistent order, then runs the given Runnable.
toFuture(Single<T>) - Static method in class com.diffplug.common.rx.RxJavaCompat
 
toFuture(Maybe<T>) - Static method in class com.diffplug.common.rx.RxJavaCompat
 
transactOn(LockBox...) - Static method in interface com.diffplug.common.rx.LockBox
Creates an OrderedLock which allows running transactions on the given list of LockBoxes.
trump(MultiSelectModel<U>) - Method in class com.diffplug.common.rx.MultiSelectModel
Mouseover and selection in this model will trump whatever is in the other.
Trumped(RxBox<Either<Optional<T>, Optional<U>>>, RxBox<Either<ImmutableSet<T>, ImmutableSet<U>>>) - Constructor for class com.diffplug.common.rx.MultiSelectModel.Trumped
 

V

valueOf(String) - Static method in enum com.diffplug.common.rx.RxOrderedSet.OnDuplicate
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.diffplug.common.rx.RxOrderedSet.OnDuplicate
Returns an array containing the constants of this enum type, in the order they are declared.

W

wrap(Runnable) - Method in class com.diffplug.common.rx.GuardedExecutor
Creates a runnable which runs on this Executor iff the guard widget is not disposed.
wrap(Observable<T>) - Static method in interface com.diffplug.common.rx.IObservable
Wraps an actual observable as an IObservable.
wrap(Runnable) - Method in class com.diffplug.common.rx.OrderedLock
Returns a Runnable which will get and release the appropriate locks before executing its argument.
wrap(Supplier<T>) - Method in class com.diffplug.common.rx.OrderedLock
Returns a Supplier which will get and release the appropriate locks before executing its argument.
A B C D E F G H I L M N O R S T V W 
Skip navigation links

com.diffplug.durian:durian-rx:3.1.0-SNAPSHOT by DiffPlug