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

A

asObservable() - Method in interface com.diffplug.common.rx.IObservable

asObservable() - Method in class com.diffplug.common.rx.RxBox.Default

C

com.diffplug.common.rx - package com.diffplug.common.rx

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 RxGetters using the BiFunction combine.

D

Default(T) - Constructor for class com.diffplug.common.rx.RxBox.Default

Creates a Holder which holds the given value.

E

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

Provides a mechanism for enforcing an invariant.

F

fire() - Method in class com.diffplug.common.rx.RateProbe

Fires the rate probe, and returns the elapsed time since the last call in nanoseconds.

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.

G

get() - Method in class com.diffplug.common.rx.RxBox.Default

Returns the value.

getDuplicatePolicy() - Method in class com.diffplug.common.rx.RxOrderedSet

Returns the duplicate policy for this RxList.

getRxExecutor() - Method in interface com.diffplug.common.rx.Rx.HasRxExecutor

H

hook(Object, Rx<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, Rx<T>) - Method in class com.diffplug.common.rx.RxTracingPolicy.LogSubscriptionTrace

I

Immutables - Class in com.diffplug.common.rx

Methods for manipulating Guava's immutable collections.

IObservable<T> - Interface in com.diffplug.common.rx

An object which can be supplied in an Observable form.

L

LogSubscriptionTrace() - Constructor for class com.diffplug.common.rx.RxTracingPolicy.LogSubscriptionTrace

M

map(Function<? super T, ? extends R>, Function<? super R, ? extends T>) - 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.

mutate(Consumer<BiMap<K, V>>) - Method in class com.diffplug.common.rx.RxBiMap

Mutates this map.

mutate(Consumer<List<T>>) - Method in class com.diffplug.common.rx.RxList

Mutates this list.

mutate(Consumer<Map<K, V>>) - Method in class com.diffplug.common.rx.RxMap

Mutates this map.

mutate(Consumer<List<T>>) - Method in class com.diffplug.common.rx.RxOrderedSet

Mutates this set.

mutate(Consumer<Set<T>>) - Method in class com.diffplug.common.rx.RxSet

Mutates this set.

mutate(Consumer<NavigableMap<K, V>>) - Method in class com.diffplug.common.rx.RxSortedMap

Mutates this map.

mutate(Consumer<NavigableSet<T>>) - Method in class com.diffplug.common.rx.RxSortedSet

Mutates this set.

mutateBiMap(ImmutableBiMap<K, V>, Consumer<BiMap<K, V>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a mutated version of the given sorted map.

mutateList(ImmutableList<T>, Consumer<List<T>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a mutated version of the given list.

mutateMap(ImmutableMap<K, V>, Consumer<Map<K, V>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a mutated version of the given map.

mutateSet(ImmutableSet<T>, Consumer<Set<T>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a mutated version of the given set.

mutateSortedMap(ImmutableSortedMap<K, V>, Consumer<NavigableMap<K, V>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a mutated version of the given sorted map.

mutateSortedSet(ImmutableSortedSet<T>, Consumer<NavigableSet<T>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a mutated version of the given sorted set.

mutatorBiMap(Consumer<BiMap<K, V>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a function which mutates a sorted map using the given mutator.

mutatorList(Consumer<List<T>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a function which mutates a list using the given mutator.

mutatorMap(Consumer<Map<K, V>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a function which mutates a map using the given mutator.

mutatorSet(Consumer<Set<T>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a function which mutates a set using the given mutator.

mutatorSortedMap(Consumer<NavigableMap<K, V>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a function which mutates a sorted map using the given mutator.

mutatorSortedSet(Consumer<NavigableSet<T>>) - Static method in class com.diffplug.common.rx.Immutables

Returns a function which mutates a sorted set using the given mutator.

N

NONE - Static variable in interface com.diffplug.common.rx.RxTracingPolicy

An RxTracingPolicy which performs no tracing, and has very low overhead.

O

of(Map<K, V>) - Static method in class com.diffplug.common.rx.RxBiMap

Creates an RxMap with the given initial value.

of(T) - Static method in interface com.diffplug.common.rx.RxBox

Creates an RxBox with the given initial value.

of(List<T>) - Static method in class com.diffplug.common.rx.RxList

Creates an RxList with the given initial value.

of(Map<K, V>) - Static method in class com.diffplug.common.rx.RxMap

Creates an RxMap with the given initial value.

of(Optional<T>) - Static method in class com.diffplug.common.rx.RxOptional

Returns an RxOptional of the given value.

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.

of(Set<T>) - Static method in class com.diffplug.common.rx.RxSet

Creates an RxSet with the given initial value.

of(SortedMap<K, V>) - Static method in class com.diffplug.common.rx.RxSortedMap

Creates an RxMap with the given initial value.

of(Map<K, V>) - Static method in class com.diffplug.common.rx.RxSortedMap

Creates an RxMap with the given initial value.

of(SortedSet<T>) - Static method in class com.diffplug.common.rx.RxSortedSet

Creates an RxSet with the given initial value.

of(Set<T>) - Static method in class com.diffplug.common.rx.RxSortedSet

Creates an RxSet with the given initial value.

ofEmpty() - Static method in class com.diffplug.common.rx.RxBiMap

Creates an RxMap with an initially empty value.

ofEmpty() - Static method in class com.diffplug.common.rx.RxList

Creates an RxList with an initially empty value.

ofEmpty() - Static method in class com.diffplug.common.rx.RxMap

Creates an RxMap with an initially empty value.

ofEmpty() - Static method in class com.diffplug.common.rx.RxOptional

Returns an empty RxOptional.

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.

ofEmpty() - Static method in class com.diffplug.common.rx.RxSet

Creates an RxSet with an initially empty value.

ofEmpty() - Static method in class com.diffplug.common.rx.RxSortedMap

Creates an RxMap with an initially empty value.

ofEmpty() - Static method in class com.diffplug.common.rx.RxSortedSet

Creates an RxSet with an initially empty value.

ofValue(T) - Static method in class com.diffplug.common.rx.RxOptional

Returns an empty RxOptional.

on(Executor) - Static method in class com.diffplug.common.rx.Rx

Mechanism for specifying a specific Executor.

on(Executor, Scheduler) - Static method in class com.diffplug.common.rx.Rx

Mechanism for specifying a specific Executor (for ListenableFuture) and Scheduler (for Observable).

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

onError(Throwable) - Method in class com.diffplug.common.rx.Rx

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

onNext(T) - Method in class com.diffplug.common.rx.Rx

onSuccess(T) - Method in class com.diffplug.common.rx.Rx

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.

optionalFrom(ImmutableCollection<T>) - Static method in class com.diffplug.common.rx.Immutables

Converts an ImmutableCollection to an Optional.

optionalToSet(Optional<T>) - Static method in class com.diffplug.common.rx.Immutables

Converts an Optional to an ImmutableSet.

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<T> - Class in com.diffplug.common.rx

Unifies the listener models of RxJava's Observable with Guava's ListenableFuture , and also adds tracing capabilities.

Rx(Consumer<T>, Consumer<Optional<Throwable>>) - Constructor for class com.diffplug.common.rx.Rx

Rx.HasRxExecutor - Interface in com.diffplug.common.rx

Marker interface which allows an Executor to specify its own Scheduler.

Rx.RxExecutor - Class in com.diffplug.common.rx

This class holds an instance of Executor (for ListenableFuture) and Scheduler (for Observable).

RxBiMap<K,V> - Class in com.diffplug.common.rx

RxBox<ImmutableBiMap<T>> with convenience methods for creating and mutating the map.

RxBiMap(ImmutableBiMap<K, V>) - Constructor for class com.diffplug.common.rx.RxBiMap

Initally holds the given collection.

RxBox<T> - Interface in com.diffplug.common.rx

RxGetter and Box combined in one: a value you can set, get, and subscribe to.

RxBox.Default<T> - Class in com.diffplug.common.rx

Standard implementation of an RxBox.

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.

RxList<T> - Class in com.diffplug.common.rx

RxBox<ImmutableList<T>> with convenience methods for creating and mutating the list.

RxList(ImmutableList<T>) - Constructor for class com.diffplug.common.rx.RxList

Initally holds the given collection.

RxMap<K,V> - Class in com.diffplug.common.rx

RxBox<ImmutableMap<T>> with convenience methods for creating and mutating the map.

RxMap(ImmutableMap<K, V>) - Constructor for class com.diffplug.common.rx.RxMap

Initally holds the given collection.

RxOptional<T> - Class in com.diffplug.common.rx

RxBox<Optional<T>> with convenience methods for creating the optional.

RxOptional(Optional<T>) - Constructor for class com.diffplug.common.rx.RxOptional

Initially holds the given value.

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.

RxSet<T> - Class in com.diffplug.common.rx

RxBox<ImmutableSet<T>> with convenience methods for creating and mutating the set.

RxSet(ImmutableSet<T>) - Constructor for class com.diffplug.common.rx.RxSet

Initally holds the given collection.

RxSortedMap<K,V> - Class in com.diffplug.common.rx

RxBox<ImmutableSortedMap<T>> with convenience methods for creating and mutating the map.

RxSortedMap(ImmutableSortedMap<K, V>) - Constructor for class com.diffplug.common.rx.RxSortedMap

Initally holds the given collection.

RxSortedSet<T> - Class in com.diffplug.common.rx

RxBox<ImmutableSortedSet<T>> with convenience methods for creating and mutating the set.

RxSortedSet(ImmutableSortedSet<T>) - Constructor for class com.diffplug.common.rx.RxSortedSet

Initally holds the given collection.

RxSubscriber - Interface in com.diffplug.common.rx

An object which can subscribe observables to Rx 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

set(Map<K, V>) - Method in class com.diffplug.common.rx.RxBiMap

Sets the value of this map.

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

Sets the value.

set(List<T>) - Method in class com.diffplug.common.rx.RxList

Sets the list to the given list.

set(Map<K, V>) - Method in class com.diffplug.common.rx.RxMap

Sets the value of this map.

set(ImmutableList<T>) - Method in class com.diffplug.common.rx.RxOrderedSet

Sets the selection.

set(Set<T>) - Method in class com.diffplug.common.rx.RxSet

Removes the given value from the set.

set(SortedMap<K, V>) - Method in class com.diffplug.common.rx.RxSortedMap

Sets the value of this map.

set(Map<K, V>) - Method in class com.diffplug.common.rx.RxSortedMap

Sets the value of this map.

set(SortedSet<T>) - Method in class com.diffplug.common.rx.RxSortedSet

Sets the value of this set.

set(Set<T>) - Method in class com.diffplug.common.rx.RxSortedSet

Sets the value of this set.

setEmpty() - Method in class com.diffplug.common.rx.RxOptional

Shortcut for set(Optional.ofEmpty()).

setValue(T) - Method in class com.diffplug.common.rx.RxOptional

Shortcut for set(Optional.of(value)).

shouldLog - Static variable in class com.diffplug.common.rx.RxTracingPolicy.LogSubscriptionTrace

The BiPredicate which determines which subscriptions should be logged.

subscribe(Observable<? extends T>, Rx<T>) - Method in class com.diffplug.common.rx.Rx.RxExecutor

subscribe(CompletionStage<? extends T>, Rx<T>) - Method in class com.diffplug.common.rx.Rx.RxExecutor

subscribe(ListenableFuture<? extends T>, Rx<T>) - Method in class com.diffplug.common.rx.Rx.RxExecutor

subscribe(Observable<? extends T>, Rx<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>, Rx<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>, Rx<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>, Rx<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>, Rx<T>) - Method in interface com.diffplug.common.rx.RxSubscriber

Subscribes the given listener to the given observable.

subscribe(ListenableFuture<? extends T>, Rx<T>) - Method in interface com.diffplug.common.rx.RxSubscriber

Subscribes the given listener to the given Guava ListenableFuture.

subscribe(CompletionStage<? extends T>, Rx<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>, Rx<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

toList() - Static method in class com.diffplug.common.rx.Immutables

A Collector which returns an ImmutableList.

toMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Static method in class com.diffplug.common.rx.Immutables

A Collector which returns an ImmutableMap using the given pair of key and value functions.

toSet() - Static method in class com.diffplug.common.rx.Immutables

A Collector which returns an ImmutableSet.

toSortedMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Static method in class com.diffplug.common.rx.Immutables

A Collector which returns an ImmutableSortedMap which is populated by the given pair of key and value functions.

toSortedMap(Comparator<K>, Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Static method in class com.diffplug.common.rx.Immutables

A Collector which returns an ImmutableSortedMap which is ordered by the given comparator, and populated by the given pair of key and value functions.

toSortedSet() - Static method in class com.diffplug.common.rx.Immutables

A Collector of Comparables which returns an ImmutableSortedSet.

toSortedSet(Comparator<T>) - Static method in class com.diffplug.common.rx.Immutables

A Collector which returns an ImmutableSortedSet which is ordered by the given comparator.

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.

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