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

A

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.

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

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

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

getRxExecutor() - Method in interface com.diffplug.common.rx.RxExecutor.Has

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.

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 class com.diffplug.common.rx.ForwardingBox

modify(Function<? super T, ? extends T>) - Method in interface com.diffplug.common.rx.LockBox

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.

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.

onCompleted() - Method in class com.diffplug.common.rx.RxListener

onError(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

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.

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`.

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.

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.

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

set(T) - Method in class com.diffplug.common.rx.Breaker

set(T) - Method in class com.diffplug.common.rx.ForwardingBox

setClosed(boolean) - Method in class com.diffplug.common.rx.Breaker

Sets that this breaker is closed or open.

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>) - 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(CompletionStage<? 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(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

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.

transactOn(LockBox...) - Static method in interface com.diffplug.common.rx.LockBox

Creates an OrderedLock which allows running transactions on the given list of LockBoxes.

W

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 W