Uses of Interface rx.functions.Func0

Uses of Interface
rx.functions.Func0

Packages that use Func0

Package	Description
rx	Rx Observables
rx.functions
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.observables

Uses of Func0 in rx

Methods in rx with parameters of type Func0

Modifier and Type	Method and Description
`<TClosing> Observable<List<T>>`	Observable.`buffer(Func0<? extends Observable<? extends TClosing>> bufferClosingSelector)` Returns an Observable that emits buffers of items it collects from the source Observable.
`<R> Observable<R>`	Observable.`collect(Func0<R> stateFactory, Action2<R,? super T> collector)` Collects items emitted by the source Observable into a single mutable data structure and returns an Observable that emits this structure.
`static <T> Observable<T>`	Observable.`defer(Func0<Observable<T>> observableFactory)` Returns an Observable that calls an Observable factory to create an Observable for each new Observer that subscribes.
`<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.`delaySubscription(Func0<? extends Observable<U>> subscriptionDelay)` Returns an Observable that delays the subscription to the source Observable until a second Observable emits an item.
`<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, int maxConcurrent)` 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, while limiting the maximum number of concurrent subscriptions to these Observables.
`<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.
`<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,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.
`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 which is disposed of on unsubscription.
`static <T,Resource> Observable<T>`	Observable.`using(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> disposeAction, boolean disposeEagerly)` Constructs an Observable that creates a dependent resource object which is disposed of just before termination if you have set `disposeEagerly` to `true` and unsubscription does not occur before termination.
`<TClosing> Observable<Observable<T>>`	Observable.`window(Func0<? extends Observable<? extends TClosing>> closingSelector)` Returns an Observable that emits windows of items it collects from the source Observable.

Uses of Func0 in rx.functions

Methods in that return

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

Methods in rx.functions with parameters of type Func0

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

Uses of Func0 in rx.internal.operators

Classes in that implement

Modifier and Type	Class and Description
`static class`	`OperatorToMap.DefaultToMapFactory<K,V>` The default map factory.
`static class`	`OperatorToMultimap.DefaultToMultimapFactory<K,V>` The default multimap factory returning a HashMap.

Methods in with parameters of type

Modifier and Type	Method and Description
`static <T,U,R> Observable<R>`	OperatorReplay.`multicastSelector(Func0<? extends ConnectableObservable<U>> connectableFactory, Func1<? super Observable<U>,? extends Observable<R>> selector)` Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.

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

Constructor and Description
	`OnSubscribeDefer(Func0<? extends Observable<? extends T>> observableFactory)`
	`OnSubscribeDelaySubscriptionWithSelector(Observable<? extends T> source, Func0<? extends Observable<U>> subscriptionDelay)`
	`OnSubscribeUsing(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> dispose, boolean disposeEagerly)`
	`OperatorBufferWithSingleObservable(Func0<? extends Observable<? extends TClosing>> bufferClosingSelector, int initialCapacity)`
	`OperatorMapNotification(Func1<? super T,? extends R> onNext, Func1<? super Throwable,? extends R> onError, Func0<? extends R> onCompleted)`
	`OperatorMulticast(Observable<? extends T> source, Func0<? extends Subject<? super T,? extends R>> subjectFactory)`
	`OperatorScan(Func0<R> initialValueFactory, Func2<R,? super T,R> accumulator)`
	`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, 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, 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.
	`OperatorWindowWithObservableFactory(Func0<? extends Observable<? extends U>> otherFactory)`

Uses of Func0 in rx.observables

Methods in rx.observables with parameters of type Func0

Modifier and Type	Method and Description
`static <S,T> Observable.OnSubscribe<T>`	SyncOnSubscribe.`createSingleState(Func0<? extends S> generator, Action2<? super S,? super Observer<? super T>> next)` Generates a synchronous `SyncOnSubscribe` that calls the provided `next` function to generate data to downstream subscribers.
`static <S,T> Observable.OnSubscribe<T>`	SyncOnSubscribe.`createSingleState(Func0<? extends S> generator, Action2<? super S,? super Observer<? super T>> next, Action1<? super S> onUnsubscribe)` Generates a synchronous `SyncOnSubscribe` that calls the provided `next` function to generate data to downstream subscribers.
`static <S,T> Observable.OnSubscribe<T>`	AsyncOnSubscribe.`createSingleState(Func0<? extends S> generator, Action3<? super S,Long,? super Observer<Observable<? extends T>>> next)` Generates a synchronous `AsyncOnSubscribe` that calls the provided `next` function to generate data to downstream subscribers.
`static <S,T> Observable.OnSubscribe<T>`	AsyncOnSubscribe.`createSingleState(Func0<? extends S> generator, Action3<? super S,Long,? super Observer<Observable<? extends T>>> next, Action1<? super S> onUnsubscribe)` Generates a synchronous `AsyncOnSubscribe` that calls the provided `next` function to generate data to downstream subscribers.
`static <S,T> Observable.OnSubscribe<T>`	SyncOnSubscribe.`createStateful(Func0<? extends S> generator, Func2<? super S,? super Observer<? super T>,? extends S> next)` Generates a synchronous `SyncOnSubscribe` that calls the provided `next` function to generate data to downstream subscribers.
`static <S,T> Observable.OnSubscribe<T>`	SyncOnSubscribe.`createStateful(Func0<? extends S> generator, Func2<? super S,? super Observer<? super T>,? extends S> next, Action1<? super S> onUnsubscribe)` Generates a synchronous `SyncOnSubscribe` that calls the provided `next` function to generate data to downstream subscribers.
`static <S,T> Observable.OnSubscribe<T>`	AsyncOnSubscribe.`createStateful(Func0<? extends S> generator, Func3<? super S,Long,? super Observer<Observable<? extends T>>,? extends S> next)` Generates a synchronous `AsyncOnSubscribe` that calls the provided `next` function to generate data to downstream subscribers.
`static <S,T> Observable.OnSubscribe<T>`	AsyncOnSubscribe.`createStateful(Func0<? extends S> generator, Func3<? super S,Long,? super Observer<Observable<? extends T>>,? extends S> next, Action1<? super S> onUnsubscribe)` Generates a synchronous `AsyncOnSubscribe` that calls the provided `next` function to generate data to downstream subscribers.