Uses of Interface
rx.functions.Action1

Packages that use Action1

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
rx.functions	Functional interfaces of functions and actions of arity 0 to 9 and related utility classes.
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.internal.util
rx.observables	Classes extending the Observable base reactive class, synchronous and asynchronous event generators.
rx.observers	Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks.
rx.plugins	Callback types and a central plugin handler class to hook into the lifecycle of the base reactive types and schedulers.
rx.subjects	Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables).

Uses of Action1 in rx

Subinterfaces of Action1 in rx

Modifier and Type	Interface	Description
static interface	Completable.CompletableOnSubscribe	Callback used for building deferred computations that takes a CompletableSubscriber.
static interface	Observable.OnSubscribe<T>	Invoked when Observable.subscribe is called.
static interface	Single.OnSubscribe<T>	Invoked when Single.execute is called.

Classes in rx that implement Action1

Modifier and Type	Class	Description
(package private) static class	Observable.OnSubscribeExtend<T>	Transforms a OnSubscribe.call() into an Observable.subscribe() call.

Methods in rx with parameters of type Action1

Modifier and Type	Method	Description
Observable<T>	Observable.doOnEach(Action1<Notification<? super T>> onNotification)	Modifies the source Observable so that it invokes an action for each item it emits.
Completable	Completable.doOnError(Action1<? super java.lang.Throwable> onError)	Returns a Completable which calls the given onError callback if this Completable emits an error.
Observable<T>	Observable.doOnError(Action1<java.lang.Throwable> onError)	Modifies the source Observable so that it invokes an action if it calls onError.
Single<T>	Single.doOnError(Action1<java.lang.Throwable> onError)	Modifies the source Single so that it invokes an action if it calls onError.
protected Completable	Completable.doOnLifecycle(Action1<? super Subscription> onSubscribe, Action1<? super java.lang.Throwable> onError, Action0 onComplete, Action0 onAfterComplete, Action0 onUnsubscribe)	Returns a Completable instance that calls the various callbacks on the specific lifecycle events.
Observable<T>	Observable.doOnNext(Action1<? super T> onNext)	Modifies the source Observable so that it invokes an action when it calls onNext.
Observable<T>	Observable.doOnRequest(Action1<java.lang.Long> onRequest)	Modifies the source Observable so that it invokes the given action when it receives a request for more items.
Completable	Completable.doOnSubscribe(Action1<? super Subscription> onSubscribe)	Returns a Completable instance that calls the given onSubscribe callback with the disposable that child subscribers receive on subscription.
Single<T>	Single.doOnSuccess(Action1<? super T> onSuccess)	Modifies the source Single so that it invokes an action when it calls onSuccess.
void	Observable.forEach(Action1<? super T> onNext)	Subscribes to the Observable and receives notifications for each element.
void	Observable.forEach(Action1<? super T> onNext, Action1<java.lang.Throwable> onError)	Subscribes to the Observable and receives notifications for each element and error events.
void	Observable.forEach(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onComplete)	Subscribes to the Observable and receives notifications for each element and the terminal events.
static <T> Observable<T>	Observable.fromAsync(Action1<AsyncEmitter<T>> asyncEmitter, AsyncEmitter.BackpressureMode backpressure)	Provides an API (via a cold Observable) that bridges the reactive world with the callback-style, generally non-backpressured world.
Observable<T>	Observable.onBackpressureDrop(Action1<? super T> onDrop)	Instructs an Observable that is emitting items faster than its observer can consume them to discard, rather than emit, those items that its observer is not prepared to observe.
Subscription	Completable.subscribe(Action0 onComplete, Action1<? super java.lang.Throwable> onError)	Subscribes to this Completable and calls back either the onError or onComplete functions.
Subscription	Observable.subscribe(Action1<? super T> onNext)	Subscribes to an Observable and provides a callback to handle the items it emits.
Subscription	Observable.subscribe(Action1<? super T> onNext, Action1<java.lang.Throwable> onError)	Subscribes to an Observable and provides callbacks to handle the items it emits and any error notification it issues.
Subscription	Observable.subscribe(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onCompleted)	Subscribes to an Observable and provides callbacks to handle the items it emits and any error or completion notification it issues.
Subscription	Single.subscribe(Action1<? super T> onSuccess)	Subscribes to a Single and provides a callback to handle the item it emits.
Subscription	Single.subscribe(Action1<? super T> onSuccess, Action1<java.lang.Throwable> onError)	Subscribes to a Single and provides callbacks to handle the item it emits or any error notification it issues.
static <R> Completable	Completable.using(Func0<R> resourceFunc0, Func1<? super R,? extends Completable> completableFunc1, Action1<? super R> disposer)	Returns a Completable instance which manages a resource along with a custom Completable instance while the subscription is active.
static <R> Completable	Completable.using(Func0<R> resourceFunc0, Func1<? super R,? extends Completable> completableFunc1, Action1<? super R> disposer, boolean eager)	Returns a Completable instance which manages a resource along with a custom Completable instance while the subscription is active and performs eager or lazy resource disposition.
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.
static <T,Resource> Single<T>	Single.using(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Single<? extends T>> singleFactory, Action1<? super Resource> disposeAction)	Constructs an Single that creates a dependent resource object which is disposed of on unsubscription.
static <T,Resource> Single<T>	Single.using(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Single<? extends T>> singleFactory, Action1<? super Resource> disposeAction, boolean disposeEagerly)	Constructs an Single 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.

Uses of Action1 in rx.functions

Classes in rx.functions that implement Action1

Modifier and Type	Class	Description
(package private) static class	Actions.Action1CallsAction0<T>
(package private) static class	Actions.EmptyAction<T0,T1,T2,T3,T4,T5,T6,T7,T8>

Methods in rx.functions that return Action1

Modifier and Type	Method	Description
static <T> Action1<T>	Actions.toAction1(Action0 action)	Wraps an Action0 instance into an Action1 instance where the latter calls the former.

Methods in rx.functions with parameters of type Action1

Modifier and Type	Method	Description
static <T0> FuncN<java.lang.Void>	Functions.fromAction(Action1<? super T0> f)	Converts an Action1 to a FuncN to allow heterogeneous handling of functions with different arities.
static <T1> Func1<T1,java.lang.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.

Uses of Action1 in rx.internal.operators

Classes in rx.internal.operators that implement Action1

Modifier and Type	Class	Description
(package private) static class	BufferUntilSubscriber.OnSubscribeAction<T>
(package private) static class	CachedObservable.CachedSubscribe<T>	Manages the subscription of child subscribers by setting up a replay producer and performs auto-connection of the very first subscription.
class	CompletableOnSubscribeConcat
class	CompletableOnSubscribeConcatArray
class	CompletableOnSubscribeConcatIterable
class	CompletableOnSubscribeMerge
class	CompletableOnSubscribeMergeArray
class	CompletableOnSubscribeMergeDelayErrorArray
class	CompletableOnSubscribeMergeDelayErrorIterable
class	CompletableOnSubscribeMergeIterable
class	CompletableOnSubscribeTimeout
class	EmptyObservableHolder	Holds a singleton instance of an empty Observable which is stateless and completes the child subscriber immediately.
class	NeverObservableHolder	Holds a singleton instance of a never Observable which is stateless doesn't call any of the Subscriber's methods.
class	OnSubscribeAmb<T>	Given multiple Observables, propagates the one that first emits an item.
class	OnSubscribeAutoConnect<T>	Wraps a ConnectableObservable and calls its connect() method once the specified number of Subscribers have subscribed.
class	OnSubscribeCollect<T,R>
class	OnSubscribeCombineLatest<T,R>
class	OnSubscribeConcatMap<T,R>	Maps a source sequence into Observables and concatenates them in order, subscribing to one at a time.
class	OnSubscribeDefer<T>	Do not create the Observable until an Observer subscribes; create a fresh Observable on each subscription.
class	OnSubscribeDelaySubscription<T>	Delays the subscription to the source by the given amount, running on the given scheduler.
class	OnSubscribeDelaySubscriptionOther<T,U>	Delays the subscription to the main source until the other observable fires an event or completes.
class	OnSubscribeDelaySubscriptionWithSelector<T,U>	Delays the subscription until the Observable emits an event.
class	OnSubscribeDetach<T>	Nulls out references to upstream data structures when the source terminates or the child unsubscribes.
class	OnSubscribeFilter<T>	Filters an Observable by discarding any items it emits that do not meet some test.
class	OnSubscribeFlattenIterable<T,R>	Flattens a sequence if Iterable sources, generated via a function, into a single sequence.
(package private) static class	OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T,R>	A custom flattener that works from a scalar value and computes the iterable during subscription time.
class	OnSubscribeFromArray<T>
class	OnSubscribeFromAsync<T>
class	OnSubscribeFromCallable<T>	Do not invoke the function until an Observer subscribes; Invokes function on each subscription.
class	OnSubscribeFromIterable<T>	Converts an Iterable sequence into an Observable.
class	OnSubscribeGroupJoin<T1,T2,D1,D2,R>	Correlates two sequences when they overlap and groups the results.
(package private) static class	OnSubscribeGroupJoin.WindowObservableFunc<T>	The reference-counted window observable.
class	OnSubscribeJoin<TLeft,TRight,TLeftDuration,TRightDuration,R>	Correlates the elements of two sequences based on overlapping durations.
class	OnSubscribeLift<T,R>	Transforms the downstream Subscriber into a Subscriber via an operator callback and calls the parent OnSubscribe.call() method with it.
class	OnSubscribeMap<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	OnSubscribeOnAssembly<T>	Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.
class	OnSubscribeOnAssemblyCompletable<T>	Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.
class	OnSubscribeOnAssemblySingle<T>	Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.
class	OnSubscribePublishMulticast<T>	Multicasts notifications coming through its input Subscriber view to its client Subscribers via lockstep backpressure mode.
class	OnSubscribeRange	Emit ints from start to end inclusive.
class	OnSubscribeRedo<T>
class	OnSubscribeReduce<T>
class	OnSubscribeReduceSeed<T,R>
class	OnSubscribeRefCount<T>	Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.
class	OnSubscribeSingle<T>	Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less.
class	OnSubscribeTakeLastOne<T>
class	OnSubscribeThrow<T>	An Observable that invokes onError when the Observer subscribes to it.
class	OnSubscribeTimerOnce	Timer that emits a single 0L and completes after the specified time.
class	OnSubscribeTimerPeriodically	Emit 0L after the initial period and ever increasing number after each period.
(package private) static class	OnSubscribeToObservableFuture.ToObservableFuture<T>
class	OnSubscribeUsing<T,Resource>	Constructs an observable sequence that depends on a resource object.
(package private) static class	OperatorGroupBy.GroupBySubscriber.EvictionAction<K>
(package private) static class	OperatorGroupBy.State<T,K>
class	OperatorSubscribeOn<T>	Subscribes Observers on the specified Scheduler.
class	OperatorWithLatestFromMany<T,R>
class	SingleDoAfterTerminate<T>	Execute an action after onSuccess or onError has been delivered.
class	SingleOnSubscribeDelaySubscriptionOther<T>	Delays the subscription to the Single until the Observable fires an event or completes.
class	SingleOnSubscribeMap<T,R>	Applies a function of your choosing to every item emitted by an Single, and emits the results of this transformation as a new Single.
class	SingleOnSubscribeUsing<T,Resource>	Generates a resource, derives a Single from it and disposes that resource once the Single terminates.
class	SingleOperatorOnErrorResumeNext<T>

Fields in rx.internal.operators declared as Action1

Modifier and Type	Field	Description
(package private) Action1<AsyncEmitter<T>>	OnSubscribeFromAsync.asyncEmitter
(package private) Action1<? super Subscription>	OnSubscribeAutoConnect.connection
private Action1<? super Resource>	OnSubscribeUsing.dispose
private Action1<? super Resource>	OnSubscribeUsing.DisposeAction.dispose
(package private) Action1<? super Resource>	SingleOnSubscribeUsing.disposeAction
(package private) Action1<? super T>	OperatorOnBackpressureDrop.onDrop
(package private) Action1<java.lang.Long>	OperatorDoOnRequest.request

Fields in rx.internal.operators with type parameters of type Action1

Modifier and Type	Field	Description
(package private) Func1<Action1<K>,java.util.Map<K,java.lang.Object>>	OperatorGroupBy.mapFactory

Methods in rx.internal.operators that return Action1

Modifier and Type	Method	Description
private Action1<Subscription>	OnSubscribeRefCount.onSubscribe(Subscriber<? super T> subscriber, java.util.concurrent.atomic.AtomicBoolean writeLocked)

Methods in rx.internal.operators with parameters of type Action1

Modifier and Type	Method	Description
void	OperatorMulticast.connect(Action1<? super Subscription> connection)
void	OperatorPublish.connect(Action1<? super Subscription> connection)
void	OperatorReplay.connect(Action1<? super Subscription> connection)
private java.util.Map<java.lang.Object,OperatorGroupBy.GroupedUnicast<K,V>>	OperatorGroupBy.GroupBySubscriber.createMap(Func1<Action1<K>,java.util.Map<K,java.lang.Object>> mapFactory, Action1<K> evictionAction)

Method parameters in rx.internal.operators with type arguments of type Action1

Modifier and Type	Method	Description
private java.util.Map<java.lang.Object,OperatorGroupBy.GroupedUnicast<K,V>>	OperatorGroupBy.GroupBySubscriber.createMap(Func1<Action1<K>,java.util.Map<K,java.lang.Object>> mapFactory, Action1<K> evictionAction)

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

Constructor	Description
DisposeAction(Action1<? super Resource> dispose, Resource resource)
OnSubscribeAutoConnect(ConnectableObservable<? extends T> source, int numberOfSubscribers, Action1<? super Subscription> connection)
OnSubscribeFromAsync(Action1<AsyncEmitter<T>> asyncEmitter, AsyncEmitter.BackpressureMode backpressure)
OnSubscribeUsing(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> dispose, boolean disposeEagerly)
OperatorDoOnRequest(Action1<java.lang.Long> request)
OperatorOnBackpressureDrop(Action1<? super T> onDrop)
SingleOnSubscribeUsing(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Single<? extends T>> observableFactory, Action1<? super Resource> disposeAction, boolean disposeEagerly)

Uses of Action1 in rx.internal.util

Classes in rx.internal.util that implement Action1

Modifier and Type	Class	Description
(package private) static class	InternalObservableUtils.ErrorNotImplementedAction
(package private) static class	ScalarSynchronousObservable.JustOnSubscribe<T>	The OnSubscribe callback for the Observable constructor.
(package private) static class	ScalarSynchronousObservable.ScalarAsyncOnSubscribe<T>	The OnSubscribe implementation that creates the ScalarAsyncProducer for each incoming subscriber.
(package private) static class	ScalarSynchronousSingle.DirectScheduledEmission<T>	Optimized observeOn for scalar value observed on the EventLoopsScheduler.
(package private) static class	ScalarSynchronousSingle.NormalScheduledEmission<T>	Emits a scalar value on a general scheduler.

Fields in rx.internal.util declared as Action1

Modifier and Type	Field	Description
static Action1<java.lang.Throwable>	InternalObservableUtils.ERROR_NOT_IMPLEMENTED	Throws an OnErrorNotImplementedException when called.
(package private) Action1<java.lang.Throwable>	ActionSubscriber.onError
(package private) Action1<? super T>	ActionSubscriber.onNext
(package private) Action1<Notification<? super T>>	ActionNotificationObserver.onNotification

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

Modifier and Type	Method	Description
void	OpenHashSet.clear(Action1<? super T> clearAction)

Constructors in rx.internal.util with parameters of type Action1

Constructor	Description
ActionNotificationObserver(Action1<Notification<? super T>> onNotification)
ActionSubscriber(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onCompleted)

Uses of Action1 in rx.observables

Classes in rx.observables that implement Action1

Modifier and Type	Class	Description
class	AsyncOnSubscribe<S,T>	A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
(package private) static class	AsyncOnSubscribe.AsyncOnSubscribeImpl<S,T>	An implementation of AsyncOnSubscribe that delegates AsyncOnSubscribe.next(Object, long, Observer), AsyncOnSubscribe.generateState(), and AsyncOnSubscribe.onUnsubscribe(Object) to provided functions/closures.
(package private) static class	AsyncOnSubscribe.UnicastSubject.State<T>
class	SyncOnSubscribe<S,T>	A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
(package private) static class	SyncOnSubscribe.SyncOnSubscribeImpl<S,T>	An implementation of SyncOnSubscribe that delegates SyncOnSubscribe#next(Object, Subscriber), SyncOnSubscribe.generateState(), and SyncOnSubscribe.onUnsubscribe(Object) to provided functions/closures.

Fields in rx.observables declared as Action1

Modifier and Type	Field	Description
private Action1<? super S>	AsyncOnSubscribe.AsyncOnSubscribeImpl.onUnsubscribe
private Action1<? super S>	SyncOnSubscribe.SyncOnSubscribeImpl.onUnsubscribe

Methods in rx.observables with parameters of type Action1

Modifier and Type	Method	Description
Observable<T>	ConnectableObservable.autoConnect(int numberOfSubscribers, Action1<? super Subscription> connection)	Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it and calls the specified callback with the Subscription associated with the established connection.
abstract void	ConnectableObservable.connect(Action1<? super Subscription> connection)	Instructs the ConnectableObservable to begin emitting the items from its underlying Observable to its Subscribers.
static <S,T> AsyncOnSubscribe<S,T>	AsyncOnSubscribe.createSingleState(Func0<? extends S> generator, Action3<? super S,java.lang.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> SyncOnSubscribe<S,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> AsyncOnSubscribe<S,T>	AsyncOnSubscribe.createStateful(Func0<? extends S> generator, Func3<? super S,java.lang.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.
static <S,T> SyncOnSubscribe<S,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 <T> SyncOnSubscribe<java.lang.Void,T>	SyncOnSubscribe.createStateless(Action1<? super Observer<? super T>> next)	Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
static <T> SyncOnSubscribe<java.lang.Void,T>	SyncOnSubscribe.createStateless(Action1<? super Observer<? super T>> next, Action0 onUnsubscribe)	Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
void	BlockingObservable.forEach(Action1<? super T> onNext)	Invokes a method on each item emitted by this BlockingObservable and blocks until the Observable completes.
void	BlockingObservable.subscribe(Action1<? super T> onNext)	Subscribes to the source and calls the given action on the current thread and rethrows any exception wrapped into OnErrorNotImplementedException.
void	BlockingObservable.subscribe(Action1<? super T> onNext, Action1<? super java.lang.Throwable> onError)	Subscribes to the source and calls the given actions on the current thread.
void	BlockingObservable.subscribe(Action1<? super T> onNext, Action1<? super java.lang.Throwable> onError, Action0 onCompleted)	Subscribes to the source and calls the given actions on the current thread.

Constructors in rx.observables with parameters of type Action1

Constructor	Description
AsyncOnSubscribeImpl(Func0<? extends S> generator, Func3<? super S,java.lang.Long,? super Observer<Observable<? extends T>>,? extends S> next, Action1<? super S> onUnsubscribe)
AsyncOnSubscribeImpl(Func3<S,java.lang.Long,Observer<Observable<? extends T>>,S> next, Action1<? super S> onUnsubscribe)
SyncOnSubscribeImpl(Func0<? extends S> generator, Func2<? super S,? super Observer<? super T>,? extends S> next, Action1<? super S> onUnsubscribe)
SyncOnSubscribeImpl(Func2<S,Observer<? super T>,S> next, Action1<? super S> onUnsubscribe)

Uses of Action1 in rx.observers

Methods in rx.observers with parameters of type Action1

Modifier and Type	Method	Description
static <T> Observer<T>	Observers.create(Action1<? super T> onNext)	Creates an Observer that receives the emissions of any Observable it subscribes to via onNext but ignores onCompleted notifications; it will throw an OnErrorNotImplementedException if onError is invoked.
static <T> Observer<T>	Observers.create(Action1<? super T> onNext, Action1<java.lang.Throwable> onError)	Creates an Observer that receives the emissions of any Observable it subscribes to via onNext and handles any onError notification but ignores an onCompleted notification.
static <T> Observer<T>	Observers.create(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onComplete)	Creates an Observer that receives the emissions of any Observable it subscribes to via onNext and handles any onError or onCompleted notifications.
static <T> Subscriber<T>	Subscribers.create(Action1<? super T> onNext)	Creates a Subscriber that receives the emissions of any Observable it subscribes to via onNext but ignores onCompleted notifications; it will throw an OnErrorNotImplementedException if onError is invoked.
static <T> Subscriber<T>	Subscribers.create(Action1<? super T> onNext, Action1<java.lang.Throwable> onError)	Creates an Subscriber that receives the emissions of any Observable it subscribes to via onNext and handles any onError notification but ignores an onCompleted notification.
static <T> Subscriber<T>	Subscribers.create(Action1<? super T> onNext, Action1<java.lang.Throwable> onError, Action0 onComplete)	Creates an Subscriber that receives the emissions of any Observable it subscribes to via onNext and handles any onError or onCompleted notifications.

Uses of Action1 in rx.plugins

Fields in rx.plugins declared as Action1

Modifier and Type	Field	Description
(package private) static Action1<java.lang.Throwable>	RxJavaHooks.onError

Methods in rx.plugins that return Action1

Modifier and Type	Method	Description
static Action1<java.lang.Throwable>	RxJavaHooks.getOnError()	Returns the current global error handler hook action or null if it is set to the default one that signals errors to the current threads UncaughtExceptionHandler.

Methods in rx.plugins with parameters of type Action1

Modifier and Type	Method	Description
static void	RxJavaHooks.setOnError(Action1<java.lang.Throwable> onError)	Sets the global error consumer action unless a lockdown is in effect.

Uses of Action1 in rx.subjects

Classes in rx.subjects that implement Action1

Modifier and Type	Class	Description
(package private) static class	ReplaySubject.ReplayState<T>	Holds onto the array of Subscriber-wrapping ReplayProducers and the buffer that holds values to be replayed; it manages subscription and signal dispatching.
(package private) class	SubjectSubscriptionManager<T>	Represents the typical state and OnSubscribe logic for a Subject implementation.
(package private) static class	UnicastSubject.State<T>	The single-consumption replaying state.

Fields in rx.subjects declared as Action1

Modifier and Type	Field	Description
(package private) Action1<SubjectSubscriptionManager.SubjectObserver<T>>	SubjectSubscriptionManager.onAdded	Action called after the subscriber has been added to the state.
(package private) Action1<SubjectSubscriptionManager.SubjectObserver<T>>	SubjectSubscriptionManager.onStart	Action called when a new subscriber subscribes but before it is added to the state.
(package private) Action1<SubjectSubscriptionManager.SubjectObserver<T>>	SubjectSubscriptionManager.onTerminated	Action called when the subscriber wants to subscribe to a terminal state.