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