Packages that use Func1

• Uses of Func1 in rx

  Subinterfaces of in

  Modifier and Type	Interface and Description
  static interface	Observable.Operator<R,T> Operator function for lifting into an Observable.
  static interface	Observable.Transformer<T,R> Transformer function used by Observable.compose(rx.Observable.Transformer<? super T, ? extends R>).

  Methods in rx with parameters of type Func1

  Modifier and Type	Method and Description
  Observable<Boolean>	Observable.all(Func1<? super T,Boolean> predicate) Returns an Observable that emits a Boolean that indicates whether all of the items emitted by the source Observable satisfy a condition.
  <TOpening,TClosing> Observable<List<T>>	Observable.buffer(Observable<? extends TOpening> bufferOpenings, Func1<? super TOpening,? extends Observable<? extends TClosing>> bufferClosingSelector) Returns an Observable that emits buffers of items it collects from the source Observable.
  <R> Observable<R>	Observable.concatMap(Func1<? super T,? extends Observable<? extends R>> func) Returns a new Observable that emits items resulting from applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then emitting the items that result from concatinating those resulting Observables.
  <U> Observable<T>	Observable.debounce(Func1<? super T,? extends Observable<U>> debounceSelector) Returns an Observable that mirrors the source Observable, except that it drops items emitted by the source Observable that are followed by another item within a computed debounce duration.
  <U,V> Observable<T>	Observable.delay(Func0<? extends Observable<U>> subscriptionDelay, Func1<? super T,? extends Observable<V>> itemDelay) Returns an Observable that delays the subscription to and emissions from the souce Observable via another Observable on a per-item basis.
  <U> Observable<T>	Observable.delay(Func1<? super T,? extends Observable<U>> itemDelay) Returns an Observable that delays the emissions of the source Observable via another Observable on a per-item basis.
  <U> Observable<T>	Observable.distinct(Func1<? super T,? extends U> keySelector) Returns an Observable that emits all items emitted by the source Observable that are distinct according to a key selector function.
  <U> Observable<T>	Observable.distinctUntilChanged(Func1<? super T,? extends U> keySelector) Returns an Observable that emits all items emitted by the source Observable that are distinct from their immediate predecessors, according to a key selector function.
  Observable<Boolean>	Observable.exists(Func1<? super T,Boolean> predicate) Returns an Observable that emits true if any item emitted by the source Observable satisfies a specified condition, otherwise false.
  Observable<T>	Observable.filter(Func1<? super T,Boolean> predicate) Filters items emitted by an Observable by only emitting those that satisfy a specified predicate.
  Observable<T>	Observable.first(Func1<? super T,Boolean> predicate) Returns an Observable that emits only the very first item emitted by the source Observable that satisfies a specified condition, or notifies of an NoSuchElementException if no such items are emitted.
  Observable<T>	Observable.firstOrDefault(T defaultValue, Func1<? super T,Boolean> predicate) Returns an Observable that emits only the very first item emitted by the source Observable that satisfies a specified condition, or a default item if the source Observable emits no such items.
  <R> Observable<R>	Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> func) Returns an Observable that emits items based on applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then merging those resulting Observables and emitting the results of this merger.
  <R> Observable<R>	Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> onNext, Func1<? super Throwable,? extends Observable<? extends R>> onError, Func0<? extends Observable<? extends R>> onCompleted) Returns an Observable that applies a function to each item emitted or notification raised by the source Observable and then flattens the Observables returned from these functions and emits the resulting items.
  <R> Observable<R>	Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> onNext, Func1<? super Throwable,? extends Observable<? extends R>> onError, Func0<? extends Observable<? extends R>> onCompleted) Returns an Observable that applies a function to each item emitted or notification raised by the source Observable and then flattens the Observables returned from these functions and emits the resulting items.
  <U,R> Observable<R>	Observable.flatMap(Func1<? super T,? extends Observable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector) Returns an Observable that emits the results of a specified function to the pair of values emitted by the source Observable and a specified collection Observable.
  <R> Observable<R>	Observable.flatMapIterable(Func1<? super T,? extends Iterable<? extends R>> collectionSelector) Returns an Observable that merges each item emitted by the source Observable with the values in an Iterable corresponding to that item that is generated by a selector.
  <U,R> Observable<R>	Observable.flatMapIterable(Func1<? super T,? extends Iterable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector) Returns an Observable that emits the results of applying a function to the pair of values from the source Observable and an Iterable corresponding to that item that is generated by a selector.
  <K> Observable<GroupedObservable<K,T>>	Observable.groupBy(Func1<? super T,? extends K> keySelector) Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as GroupedObservables, one GroupedObservable per group.
  <K,R> Observable<GroupedObservable<K,R>>	Observable.groupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends R> elementSelector) Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as GroupedObservables, one GroupedObservable per group.
  <K,R> Observable<GroupedObservable<K,R>>	Observable.groupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends R> elementSelector) Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as GroupedObservables, one GroupedObservable per group.
  <T2,D1,D2,R> Observable<R>	Observable.groupJoin(Observable<T2> right, Func1<? super T,? extends Observable<D1>> leftDuration, Func1<? super T2,? extends Observable<D2>> rightDuration, Func2<? super T,? super Observable<T2>,? extends R> resultSelector) Returns an Observable that correlates two Observables when they overlap in time and groups the results.
  <T2,D1,D2,R> Observable<R>	Observable.groupJoin(Observable<T2> right, Func1<? super T,? extends Observable<D1>> leftDuration, Func1<? super T2,? extends Observable<D2>> rightDuration, Func2<? super T,? super Observable<T2>,? extends R> resultSelector) Returns an Observable that correlates two Observables when they overlap in time and groups the results.
  <TRight,TLeftDuration,TRightDuration,R> Observable<R>	Observable.join(Observable<TRight> right, Func1<T,Observable<TLeftDuration>> leftDurationSelector, Func1<TRight,Observable<TRightDuration>> rightDurationSelector, Func2<T,TRight,R> resultSelector) Correlates the items emitted by two Observables based on overlapping durations.
  <TRight,TLeftDuration,TRightDuration,R> Observable<R>	Observable.join(Observable<TRight> right, Func1<T,Observable<TLeftDuration>> leftDurationSelector, Func1<TRight,Observable<TRightDuration>> rightDurationSelector, Func2<T,TRight,R> resultSelector) Correlates the items emitted by two Observables based on overlapping durations.
  Observable<T>	Observable.last(Func1<? super T,Boolean> predicate) Returns an Observable that emits only the last item emitted by the source Observable that satisfies a given condition, or notifies of a NoSuchElementException if no such items are emitted.
  Observable<T>	Observable.lastOrDefault(T defaultValue, Func1<? super T,Boolean> predicate) Returns an Observable that emits only the last item emitted by the source Observable that satisfies a specified condition, or a default item if no such item is emitted by the source Observable.
  <R> Observable<R>	Observable.map(Func1<? super T,? extends R> func) Returns an Observable that applies a specified function to each item emitted by the source Observable and emits the results of these function applications.
  Observable<T>	Observable.onErrorResumeNext(Func1<Throwable,? extends Observable<? extends T>> resumeFunction) Instructs an Observable to pass control to another Observable rather than invoking onError if it encounters an error.
  Observable<T>	Observable.onErrorReturn(Func1<Throwable,? extends T> resumeFunction) Instructs an Observable to emit an item (returned by a specified function) rather than invoking onError if it encounters an error.
  <R> Observable<R>	Observable.publish(Func1<? super Observable<T>,? extends Observable<R>> selector) Returns an Observable that emits the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the underlying sequence.
  Observable<T>	Observable.repeatWhen(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler) Returns an Observable that emits the same values as the source Observable with the exception of an onCompleted.
  Observable<T>	Observable.repeatWhen(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler, Scheduler scheduler) Returns an Observable that emits the same values as the source Observable with the exception of an onCompleted.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector) Returns an Observable that emits items that are the results of invoking a specified selector on the items emitted by a ConnectableObservable that shares a single subscription to the source Observable.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying bufferSize notifications.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, long time, TimeUnit unit) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying no more than bufferSize items that were emitted within a specified time window.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying no more than bufferSize items that were emitted within a specified time window.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, Scheduler scheduler) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying a maximum of bufferSize items.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, long time, TimeUnit unit) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, Scheduler scheduler) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable.
  Observable<T>	Observable.retryWhen(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler) Returns an Observable that emits the same values as the source observable with the exception of an onError.
  Observable<T>	Observable.retryWhen(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler, Scheduler scheduler) Returns an Observable that emits the same values as the source observable with the exception of an onError.
  Observable<T>	Observable.single(Func1<? super T,Boolean> predicate) Returns an Observable that emits the single item emitted by the source Observable that matches a specified predicate, if that Observable emits one such item.
  Observable<T>	Observable.singleOrDefault(T defaultValue, Func1<? super T,Boolean> predicate) Returns an Observable that emits the single item emitted by the source Observable that matches a predicate, if that Observable emits only one such item, or a default item if the source Observable emits no such items.
  Observable<T>	Observable.skipWhile(Func1<? super T,Boolean> predicate) Returns an Observable that skips all items emitted by the source Observable as long as a specified condition holds true, but emits all further source items as soon as the condition becomes false.
  <R> Observable<R>	Observable.switchMap(Func1<? super T,? extends Observable<? extends R>> func) Returns a new Observable by applying a function that you supply to each item emitted by the source Observable that returns an Observable, and then emitting the items emitted by the most recently emitted of these Observables.
  Observable<T>	Observable.takeFirst(Func1<? super T,Boolean> predicate) Returns an Observable that emits only the very first item emitted by the source Observable that satisfies a specified condition.
  Observable<T>	Observable.takeWhile(Func1<? super T,Boolean> predicate) Returns an Observable that emits items emitted by the source Observable so long as each item satisfied a specified condition, and then completes as soon as this condition is not satisfied.
  <U,V> Observable<T>	Observable.timeout(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector) Returns an Observable that mirrors the source Observable, but notifies observers of a TimeoutException if either the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows defined by other Observables.
  <U,V> Observable<T>	Observable.timeout(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other) Returns an Observable that mirrors the source Observable, but switches to a fallback Observable if either the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows defined by other Observables.
  <V> Observable<T>	Observable.timeout(Func1<? super T,? extends Observable<V>> timeoutSelector) Returns an Observable that mirrors the source Observable, but notifies observers of a TimeoutException if an item emitted by the source Observable doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by an Observable that is a function of the previous item.
  <V> Observable<T>	Observable.timeout(Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other) Returns an Observable that mirrors the source Observable, but that switches to a fallback Observable if an item emitted by the source Observable doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by an Observable that is a function of the previous item.
  <K> Observable<Map<K,T>>	Observable.toMap(Func1<? super T,? extends K> keySelector) Returns an Observable that emits a single HashMap containing all items emitted by the source Observable, mapped by the keys returned by a specified keySelector function.
  <K,V> Observable<Map<K,V>>	Observable.toMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) Returns an Observable that emits a single HashMap containing values corresponding to items emitted by the source Observable, mapped by the keys returned by a specified keySelector function.
  <K,V> Observable<Map<K,V>>	Observable.toMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) Returns an Observable that emits a single HashMap containing values corresponding to items emitted by the source Observable, mapped by the keys returned by a specified keySelector function.
  <K,V> Observable<Map<K,V>>	Observable.toMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,V>> mapFactory) Returns an Observable that emits a single Map, returned by a specified mapFactory function, that contains keys and values extracted from the items emitted by the source Observable.
  <K,V> Observable<Map<K,V>>	Observable.toMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,V>> mapFactory) Returns an Observable that emits a single Map, returned by a specified mapFactory function, that contains keys and values extracted from the items emitted by the source Observable.
  <K> Observable<Map<K,Collection<T>>>	Observable.toMultimap(Func1<? super T,? extends K> keySelector) Returns an Observable that emits a single HashMap that contains an ArrayList of items emitted by the source Observable keyed by a specified keySelector function.
  <K,V> Observable<Map<K,Collection<V>>>	Observable.toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) Returns an Observable that emits a single HashMap that contains an ArrayList of values extracted by a specified valueSelector function from items emitted by the source Observable, keyed by a specified keySelector function.
  <K,V> Observable<Map<K,Collection<V>>>	Observable.toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) Returns an Observable that emits a single HashMap that contains an ArrayList of values extracted by a specified valueSelector function from items emitted by the source Observable, keyed by a specified keySelector function.
  <K,V> Observable<Map<K,Collection<V>>>	Observable.toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,Collection<V>>> mapFactory) Returns an Observable that emits a single Map, returned by a specified mapFactory function, that contains an ArrayList of values, extracted by a specified valueSelector function from items emitted by the source Observable and keyed by the keySelector function.
  <K,V> Observable<Map<K,Collection<V>>>	Observable.toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,Collection<V>>> mapFactory) Returns an Observable that emits a single Map, returned by a specified mapFactory function, that contains an ArrayList of values, extracted by a specified valueSelector function from items emitted by the source Observable and keyed by the keySelector function.
  <K,V> Observable<Map<K,Collection<V>>>	Observable.toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,Collection<V>>> mapFactory, Func1<? super K,? extends Collection<V>> collectionFactory) Returns an Observable that emits a single Map, returned by a specified mapFactory function, that contains a custom collection of values, extracted by a specified valueSelector function from items emitted by the source Observable, and keyed by the keySelector function.
  <K,V> Observable<Map<K,Collection<V>>>	Observable.toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,Collection<V>>> mapFactory, Func1<? super K,? extends Collection<V>> collectionFactory) Returns an Observable that emits a single Map, returned by a specified mapFactory function, that contains a custom collection of values, extracted by a specified valueSelector function from items emitted by the source Observable, and keyed by the keySelector function.
  <K,V> Observable<Map<K,Collection<V>>>	Observable.toMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,Collection<V>>> mapFactory, Func1<? super K,? extends Collection<V>> collectionFactory) Returns an Observable that emits a single Map, returned by a specified mapFactory function, that contains a custom collection of values, extracted by a specified valueSelector function from items emitted by the source Observable, and keyed by the keySelector function.
  static <T,Resource> Observable<T>	Observable.using(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> disposeAction) Constructs an Observable that creates a dependent resource object.
  <TOpening,TClosing> Observable<Observable<T>>	Observable.window(Observable<? extends TOpening> windowOpenings, Func1<? super TOpening,? extends Observable<? extends TClosing>> closingSelector) Returns an Observable that emits windows of items it collects from the source Observable.

• Uses of Func1 in rx.functions

  Methods in that return

  Modifier and Type	Method and Description
  static <T1> Func1<T1,Void>	Actions.toFunc(Action1<T1> action) Converts an Action1 to a function that calls the action and returns null.
  static <T1,R> Func1<T1,R>	Actions.toFunc(Action1<T1> action, R result) Converts an Action1 to a function that calls the action and returns a specified value.

  Methods in rx.functions with parameters of type Func1

  Modifier and Type	Method and Description
  static <T0,R> FuncN<R>	Functions.fromFunc(Func1<? super T0,? extends R> f) Converts a Func1 to a FuncN to allow heterogeneous handling of functions with different arities.

• Uses of Func1 in rx.internal.operators

  Classes in that implement

  Modifier and Type	Class and Description
  static class	OnSubscribeRedo.RedoFinite
  static class	OnSubscribeRedo.RetryWithPredicate
  class	OperatorAll<T> Returns an Observable that emits a Boolean that indicates whether all items emitted by an Observable satisfy a condition.
  class	OperatorAny<T> Returns an Observable that emits true if any element of an observable sequence satisfies a condition, otherwise false.
  class	OperatorAsObservable<T> Hides the identity of another observable.
  class	OperatorBufferWithSingleObservable<T,TClosing> This operation takes values from the specified Observable source and stores them in a buffer until the Observable constructed using the Func0 argument, produces a value.
  class	OperatorBufferWithSize<T> This operation takes values from the specified Observable source and stores them in all active chunks until the buffer contains a specified number of elements.
  class	OperatorBufferWithStartEndObservable<T,TOpening,TClosing> This operation takes values from the specified Observable source and stores them in the currently active chunks.
  class	OperatorBufferWithTime<T> This operation takes values from the specified Observable source and stores them in a buffer.
  class	OperatorCast<T,R> Converts the elements of an observable sequence to the specified type.
  class	OperatorConcat<T> Returns an Observable that emits the items emitted by two or more Observables, one after the other.
  class	OperatorDebounceWithSelector<T,U> Delay the emission via another observable if no new source appears in the meantime.
  class	OperatorDebounceWithTime<T> This operation filters out events which are published too quickly in succession.
  class	OperatorDefaultIfEmpty<T> Returns the elements of the specified sequence or the specified default value in a singleton sequence if the sequence is empty.
  class	OperatorDelay<T> Delays the emission of onNext events by a given amount of time.
  class	OperatorDelayWithSelector<T,V> Delay the subscription and emission of the source items by a per-item observable that fires its first element.
  class	OperatorDematerialize<T> Reverses the effect of OperatorMaterialize by transforming the Notification objects emitted by a source Observable into the items or notifications they represent.
  class	OperatorDistinct<T,U> Returns an Observable that emits all distinct items emitted by the source.
  class	OperatorDistinctUntilChanged<T,U> Returns an Observable that emits all sequentially distinct items emitted by the source.
  class	OperatorDoOnEach<T> Converts the elements of an observable sequence to the specified type.
  class	OperatorDoOnSubscribe<T> This operator modifies an Observable so a given action is invoked when the Observable is subscribed.
  class	OperatorDoOnUnsubscribe<T> This operator modifies an Observable so a given action is invoked when the Observable is unsubscribed.
  class	OperatorElementAt<T> Returns the element at a specified index in a sequence.
  class	OperatorFilter<T> Filters an Observable by discarding any items it emits that do not meet some test.
  class	OperatorFinally<T> Registers an action to be called after an Observable invokes onComplete or onError.
  class	OperatorGroupBy<T,K,R> Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as Observables, one Observable per group.
  class	OperatorMap<T,R> Applies a function of your choosing to every item emitted by an Observable, and emits the results of this transformation as a new Observable.
  class	OperatorMapNotification<T,R> Applies a function of your choosing to every item emitted by an Observable, and emits the results of this transformation as a new Observable.
  class	OperatorMapPair<T,U,R> An Observable.Operator that pairs up items emitted by a source Observable with the sequence of items emitted by the Observable that is derived from each item by means of a selector, and emits the results of this pairing.
  class	OperatorMaterialize<T> Turns all of the notifications from an Observable into onNext emissions, and marks them with their original notification types within Notification objects.
  class	OperatorMerge<T> Flattens a list of Observables into one Observable, without any transformation.
  class	OperatorMergeDelayError<T> This behaves like OperatorMerge except that if any of the merged Observables notify of an error via onError, mergeDelayError will refrain from propagating that error notification until all of the merged Observables have finished emitting items.
  class	OperatorMergeMaxConcurrent<T> Flattens a list of Observables into one Observable sequence, without any transformation.
  class	OperatorObserveOn<T> Delivers events on the specified Scheduler asynchronously via an unbounded buffer.
  class	OperatorOnBackpressureBuffer<T>
  class	OperatorOnBackpressureDrop<T>
  class	OperatorOnErrorFlatMap<T> Allows inserting onNext events into a stream when onError events are received and continuing the original sequence instead of terminating.
  class	OperatorOnErrorResumeNextViaFunction<T> Instruct an Observable to pass control to another Observable (the return value of a function) rather than invoking onError if it encounters an error.
  class	OperatorOnErrorResumeNextViaObservable<T> Instruct an Observable to pass control to another Observable rather than invoking onError if it encounters an error.
  class	OperatorOnErrorReturn<T> Instruct an Observable to emit a particular item to its Observer's onNext method rather than invoking onError if it encounters an error.
  class	OperatorOnExceptionResumeNextViaObservable<T> Instruct an Observable to pass control to another Observable rather than invoking onError if it encounters an error of type Exception.
  class	OperatorRetryWithPredicate<T>
  class	OperatorSampleWithObservable<T,U> Sample with the help of another observable.
  class	OperatorSampleWithTime<T> Returns an Observable that emits the results of sampling the items emitted by the source Observable at a specified time interval.
  class	OperatorScan<R,T> Returns an Observable that applies a function to the first item emitted by a source Observable, then feeds the result of that function along with the second item emitted by an Observable into the same function, and so on until all items have been emitted by the source Observable, emitting the result of each of these iterations.
  class	OperatorSerialize<T>
  class	OperatorSingle<T> If the Observable completes after emitting a single item that matches a predicate, return an Observable containing that item.
  class	OperatorSkip<T> Returns an Observable that skips the first num items emitted by the source Observable.
  class	OperatorSkipLast<T> Bypasses a specified number of elements at the end of an observable sequence.
  class	OperatorSkipLastTimed<T> Skip delivering values in the time window before the values.
  class	OperatorSkipTimed<T> Skips elements until a specified time elapses.
  class	OperatorSkipUntil<T,U> Skip elements from the source Observable until the secondary observable fires an element.
  class	OperatorSkipWhile<T> Skips any emitted source items as long as the specified condition holds true.
  class	OperatorSubscribeOn<T> Subscribes Observers on the specified Scheduler.
  class	OperatorSwitch<T> Transforms an Observable that emits Observables into a single Observable that emits the items emitted by the most recently published of those Observables.
  class	OperatorTake<T> An Observable that emits the first num items emitted by the source Observable.
  class	OperatorTakeLast<T> Returns an Observable that emits the last count items emitted by the source Observable.
  class	OperatorTakeLastTimed<T> Returns an Observable that emits the last count items emitted by the source Observable.
  class	OperatorTakeTimed<T> Takes values from the source until the specific time ellapses.
  class	OperatorTakeUntil<T,E> Returns an Observable that emits the items from the source Observable until another Observable emits an item.
  class	OperatorTakeWhile<T> Returns an Observable that emits items emitted by the source Observable as long as a specified condition is true.
  class	OperatorThrottleFirst<T> Throttle by windowing a stream and returning the first value in each window.
  class	OperatorTimeInterval<T> Records the time interval between consecutive elements in an observable sequence.
  class	OperatorTimeout<T> Applies a timeout policy for each element in the observable sequence, using the specified scheduler to run timeout timers.
  class	OperatorTimeoutWithSelector<T,U,V> Returns an Observable that mirrors the source Observable.
  class	OperatorTimestamp<T> Wraps each item emitted by a source Observable in a Timestamped object.
  class	OperatorToMap<T,K,V> Maps the elements of the source observable into a java.util.Map instance and emits that once the source observable completes.
  class	OperatorToMultimap<T,K,V> Maps the elements of the source observable into a multimap (Map<K, Collection<V>>) where each key entry has a collection of the source's values.
  static class	OperatorToMultimap.DefaultMultimapCollectionFactory<K,V> The default collection factory for a key in the multimap returning an ArrayList independent of the key.
  class	OperatorToObservableList<T> Returns an Observable that emits a single item, a list composed of all the items emitted by the source Observable.
  class	OperatorToObservableSortedList<T> Return an Observable that emits the items emitted by the source Observable, in a sorted order (each item emitted by the Observable must implement Comparable with respect to all other items in the sequence, or you must pass in a sort function).
  class	OperatorUnsubscribeOn<T> Unsubscribes on the specified Scheduler.
  class	OperatorWindowWithObservable<T,U> Creates non-overlapping windows of items where each window is terminated by an event from a secondary observable and a new window is started immediately.
  class	OperatorWindowWithSize<T> Creates windows of values into the source sequence with skip frequency and size bounds.
  class	OperatorWindowWithStartEndObservable<T,U,V> Creates potentially overlapping windows of the source items where each window is started by a value emitted by an observable and closed when an associated Observable emits a value or completes.
  class	OperatorWindowWithTime<T> Creates windows of values into the source sequence with timed window creation, length and size bounds.
  class	OperatorZip<R> Returns an Observable that emits the results of a function applied to sets of items emitted, in sequence, by two or more other Observables.
  class	OperatorZipIterable<T1,T2,R>

  Fields in declared as

  Modifier and Type	Field and Description
  protected Func1<? super T1,? extends Observable<D1>>	OnSubscribeGroupJoin.leftDuration
  protected Func1<? super T2,? extends Observable<D2>>	OnSubscribeGroupJoin.rightDuration

  Methods in that return

  Modifier and Type	Method and Description
  static <T,U> Func1<T,Observable<U>>	OperatorMapPair.convertSelector(Func1<? super T,? extends Iterable<? extends U>> selector) Creates the function that generates a Observable based on an item emitted by another Observable.

  Methods in with parameters of type

  Modifier and Type	Method and Description
  static <T,U> Func1<T,Observable<U>>	OperatorMapPair.convertSelector(Func1<? super T,? extends Iterable<? extends U>> selector) Creates the function that generates a Observable based on an item emitted by another Observable.
  static <T,R> Observable<R>	OperatorPublish.create(Observable<? extends T> source, Func1<? super Observable<T>,? extends Observable<R>> selector)
  static <T> Observable<T>	OnSubscribeRedo.redo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler, Scheduler scheduler)
  static <T> Observable<T>	OnSubscribeRedo.repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler)
  static <T> Observable<T>	OnSubscribeRedo.repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler, Scheduler scheduler)
  static <T> Observable<T>	OnSubscribeRedo.retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler)
  static <T> Observable<T>	OnSubscribeRedo.retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler, Scheduler scheduler)
  static <T> Func2<T,Integer,Boolean>	OperatorSkipWhile.toPredicate2(Func1<? super T,Boolean> predicate) Convert to Func2 type predicate.

  Constructors in rx.internal.operators with parameters of type Func1

  Constructor and Description
  	OnSubscribeGroupJoin(Observable<T1> left, Observable<T2> right, Func1<? super T1,? extends Observable<D1>> leftDuration, Func1<? super T2,? extends Observable<D2>> rightDuration, Func2<? super T1,? super Observable<T2>,? extends R> resultSelector)
  	OnSubscribeGroupJoin(Observable<T1> left, Observable<T2> right, Func1<? super T1,? extends Observable<D1>> leftDuration, Func1<? super T2,? extends Observable<D2>> rightDuration, Func2<? super T1,? super Observable<T2>,? extends R> resultSelector)
  	OnSubscribeJoin(Observable<TLeft> left, Observable<TRight> right, Func1<TLeft,Observable<TLeftDuration>> leftDurationSelector, Func1<TRight,Observable<TRightDuration>> rightDurationSelector, Func2<TLeft,TRight,R> resultSelector)
  	OnSubscribeJoin(Observable<TLeft> left, Observable<TRight> right, Func1<TLeft,Observable<TLeftDuration>> leftDurationSelector, Func1<TRight,Observable<TRightDuration>> rightDurationSelector, Func2<TLeft,TRight,R> resultSelector)
  	OnSubscribeMulticastSelector(Observable<? extends TInput> source, Func0<? extends Subject<? super TInput,? extends TIntermediate>> subjectFactory, Func1<? super Observable<TIntermediate>,? extends Observable<TResult>> resultSelector)
  	OnSubscribeUsing(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> dispose)
  	OperatorAll(Func1<? super T,Boolean> predicate)
  	OperatorAny(Func1<? super T,Boolean> predicate, boolean returnOnEmpty)
  	OperatorBufferWithStartEndObservable(Observable<? extends TOpening> bufferOpenings, Func1<? super TOpening,? extends Observable<? extends TClosing>> bufferClosingSelector)
  	OperatorDebounceWithSelector(Func1<? super T,? extends Observable<U>> selector)
  	OperatorDelayWithSelector(Observable<? extends T> source, Func1<? super T,? extends Observable<V>> itemDelay)
  	OperatorDistinct(Func1<? super T,? extends U> keySelector)
  	OperatorDistinctUntilChanged(Func1<? super T,? extends U> keySelector)
  	OperatorFilter(Func1<? super T,Boolean> predicate)
  	OperatorGroupBy(Func1<? super T,? extends K> keySelector)
  	OperatorGroupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends R> valueSelector)
  	OperatorGroupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends R> valueSelector)
  	OperatorMap(Func1<? super T,? extends R> transformer)
  	OperatorMapNotification(Func1<? super T,? extends R> onNext, Func1<? super Throwable,? extends R> onError, Func0<? extends R> onCompleted)
  	OperatorMapNotification(Func1<? super T,? extends R> onNext, Func1<? super Throwable,? extends R> onError, Func0<? extends R> onCompleted)
  	OperatorMapPair(Func1<? super T,? extends Observable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector)
  	OperatorOnErrorFlatMap(Func1<OnErrorThrowable,? extends Observable<? extends T>> f)
  	OperatorOnErrorResumeNextViaFunction(Func1<Throwable,? extends Observable<? extends T>> f)
  	OperatorOnErrorReturn(Func1<Throwable,? extends T> resultFunction)
  	OperatorTakeWhile(Func1<? super T,Boolean> underlying)
  	OperatorTimeoutWithSelector(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T,? extends Observable<V>> timeoutSelector, Observable<? extends T> other)
  	OperatorToMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) ToMap with key selector, value selector and default HashMap factory.
  	OperatorToMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) ToMap with key selector, value selector and default HashMap factory.
  	OperatorToMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,V>> mapFactory) ToMap with key selector, value selector and custom Map factory.
  	OperatorToMap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,V>> mapFactory) ToMap with key selector, value selector and custom Map factory.
  	OperatorToMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) ToMultimap with key selector, custom value selector, default HashMap factory and default ArrayList collection factory.
  	OperatorToMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector) ToMultimap with key selector, custom value selector, default HashMap factory and default ArrayList collection factory.
  	OperatorToMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,Collection<V>>> mapFactory) ToMultimap with key selector, custom value selector, custom Map factory and default ArrayList collection factory.
  	OperatorToMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,Collection<V>>> mapFactory) ToMultimap with key selector, custom value selector, custom Map factory and default ArrayList collection factory.
  	OperatorToMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,Collection<V>>> mapFactory, Func1<? super K,? extends Collection<V>> collectionFactory) ToMultimap with key selector, custom value selector, custom Map factory and custom collection factory.
  	OperatorToMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,Collection<V>>> mapFactory, Func1<? super K,? extends Collection<V>> collectionFactory) ToMultimap with key selector, custom value selector, custom Map factory and custom collection factory.
  	OperatorToMultimap(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func0<? extends Map<K,Collection<V>>> mapFactory, Func1<? super K,? extends Collection<V>> collectionFactory) ToMultimap with key selector, custom value selector, custom Map factory and custom collection factory.
  	OperatorWindowWithStartEndObservable(Observable<? extends U> windowOpenings, Func1<? super U,? extends Observable<? extends V>> windowClosingSelector)

• Uses of Func1 in rx.internal.util

  Methods in that return

  Modifier and Type	Method and Description
  static <T> Func1<? super T,Boolean>	UtilityFunctions.alwaysFalse() Returns a function that always returns false.
  static <T> Func1<? super T,Boolean>	UtilityFunctions.alwaysTrue() Returns a function that always returns true.
  static <T> Func1<T,T>	UtilityFunctions.identity() Returns a function that always returns the Object it is passed.

  Methods in rx.internal.util with parameters of type Func1

  Modifier and Type	Method and Description
  int	IndexedRingBuffer.forEach(Func1<? super E,Boolean> action)
  int	IndexedRingBuffer.forEach(Func1<? super E,Boolean> action, int startIndex)
  int	SubscriptionIndexedRingBuffer.forEach(Func1<T,Boolean> action)
  int	SubscriptionIndexedRingBuffer.forEach(Func1<T,Boolean> action, int startIndex)

• Uses of Func1 in rx.observables

  Methods in rx.observables with parameters of type Func1

  Modifier and Type	Method and Description
  T	BlockingObservable.first(Func1<? super T,Boolean> predicate) Returns the first item emitted by this BlockingObservable that matches a predicate, or throws NoSuchElementException if it emits no such item.
  T	BlockingObservable.firstOrDefault(T defaultValue, Func1<? super T,Boolean> predicate) Returns the first item emitted by this BlockingObservable that matches a predicate, or a default value if it emits no such items.
  T	BlockingObservable.last(Func1<? super T,Boolean> predicate) Returns the last item emitted by this BlockingObservable that matches a predicate, or throws NoSuchElementException if it emits no such items.
  T	BlockingObservable.lastOrDefault(T defaultValue, Func1<? super T,Boolean> predicate) Returns the last item emitted by this BlockingObservable that matches a predicate, or a default value if it emits no such items.
  T	BlockingObservable.single(Func1<? super T,Boolean> predicate) If this BlockingObservable completes after emitting a single item that matches a given predicate, return that item, otherwise throw a NoSuchElementException.
  T	BlockingObservable.singleOrDefault(T defaultValue, Func1<? super T,Boolean> predicate) If this BlockingObservable completes after emitting a single item that matches a predicate, return that item; if it emits more than one such item, throw an IllegalArgumentException; if it emits no items, return a default value.