Packages that use Action1

• Uses of Action1 in rx

  Subinterfaces of in

  Modifier and Type	Interface and Description
  static interface	Observable.OnSubscribe<T> Invoked when Observable.subscribe is called.
  static interface	Single.OnSubscribe<T> Invoked when Single.execute is called.

  Methods in rx with parameters of type Action1

  Modifier and Type	Method and 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.
  Single<T>	Single.doOnError(Action1<Throwable> onError) Modifies the source Single so that it invokes an action if it calls onError.
  Observable<T>	Observable.doOnError(Action1<Throwable> onError) Modifies the source Observable so that it invokes an action if it calls onError.
  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<Long> onRequest) Modifies the source Observable so that it invokes the given action when it receives a request for more items.
  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<Throwable> onError) Subscribes to the Observable and receives notifications for each element and error events.
  void	Observable.forEach(Action1<? super T> onNext, Action1<Throwable> onError) Subscribes to the Observable and receives notifications for each element and error events.
  void	Observable.forEach(Action1<? super T> onNext, Action1<Throwable> onError, Action0 onComplete) Subscribes to the Observable and receives notifications for each element and the terminal events.
  void	Observable.forEach(Action1<? super T> onNext, Action1<Throwable> onError, Action0 onComplete) Subscribes to the Observable and receives notifications for each element and the terminal events.
  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	Single.subscribe(Action1<? super T> onSuccess) Subscribes to a Single and provides a callback to handle the item it emits.
  Subscription	Observable.subscribe(Action1<? super T> onNext) Subscribes to an Observable and provides a callback to handle the items it emits.
  Subscription	Single.subscribe(Action1<? super T> onSuccess, Action1<Throwable> onError) Subscribes to a Single and provides callbacks to handle the item it emits or any error notification it issues.
  Subscription	Single.subscribe(Action1<? super T> onSuccess, Action1<Throwable> onError) Subscribes to a Single and provides callbacks to handle the item it emits or any error notification it issues.
  Subscription	Observable.subscribe(Action1<? super T> onNext, Action1<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<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<Throwable> onError, Action0 onComplete) Subscribes to an Observable and provides callbacks to handle the items it emits and any error or completion notification it issues.
  Subscription	Observable.subscribe(Action1<? super T> onNext, Action1<Throwable> onError, Action0 onComplete) Subscribes to an Observable and provides callbacks to handle the items it emits and any error or completion notification it issues.
  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.

• Uses of Action1 in rx.functions

  Methods in rx.functions with parameters of type Action1

  Modifier and Type	Method and Description
  static <T0> FuncN<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,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 that implement

  Modifier and Type	Class and Description
  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	OnSubscribeCombineLatest<T,R> Returns an Observable that combines the emissions of multiple source observables.
  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	OnSubscribeDelaySubscriptionWithSelector<T,U> Delays the subscription until the Observable emits an event.
  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> Corrrelates two sequences when they overlap and groups the results.
  class	OnSubscribeJoin<TLeft,TRight,TLeftDuration,TRightDuration,R> Correlates the elements of two sequences based on overlapping durations.
  class	OnSubscribeRange Emit ints from start to end inclusive.
  class	OnSubscribeRedo<T>
  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	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.
  class	OnSubscribeUsing<T,Resource> Constructs an observable sequence that depends on a resource object.

  Methods in with parameters of type

  Modifier and Type	Method and Description
  void	OperatorPublish.connect(Action1<? super Subscription> connection)
  void	OperatorReplay.connect(Action1<? super Subscription> connection)
  void	OperatorMulticast.connect(Action1<? super Subscription> connection)

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

  Constructor and Description
  	OnSubscribeAutoConnect(ConnectableObservable<? extends T> source, int numberOfSubscribers, Action1<? super Subscription> connection)
  	OnSubscribeUsing(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> dispose, boolean disposeEagerly)
  	OperatorDoOnRequest(Action1<Long> request)
  	OperatorOnBackpressureDrop(Action1<? super T> onDrop)

• Uses of Action1 in rx.observables

  Classes in that implement

  Modifier and Type	Class and Description
  class	AsyncOnSubscribe<S,T> A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
  class	SyncOnSubscribe<S,T> A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.

  Methods in rx.observables with parameters of type Action1

  Modifier and Type	Method and 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> 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, 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, 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, Action1<? super S> onUnsubscribe) Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
  static <T> Observable.OnSubscribe<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> Observable.OnSubscribe<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 Throwable> onError) Subscribes to the source and calls the given actions on the current thread.
  void	BlockingObservable.subscribe(Action1<? super T> onNext, Action1<? super Throwable> onError) Subscribes to the source and calls the given actions on the current thread.
  void	BlockingObservable.subscribe(Action1<? super T> onNext, Action1<? super Throwable> onError, Action0 onCompleted) Subscribes to the source and calls the given actions on the current thread.
  void	BlockingObservable.subscribe(Action1<? super T> onNext, Action1<? super Throwable> onError, Action0 onCompleted) Subscribes to the source and calls the given actions on the current thread.

• Uses of Action1 in rx.observers

  Methods in rx.observers with parameters of type Action1

  Modifier and Type	Method and Description
  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 onError and onCompleted notifications.
  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> Subscriber<T>	Subscribers.create(Action1<? super T> onNext, Action1<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<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> Observer<T>	Observers.create(Action1<? super T> onNext, Action1<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<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> Subscriber<T>	Subscribers.create(Action1<? super T> onNext, Action1<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.
  static <T> Subscriber<T>	Subscribers.create(Action1<? super T> onNext, Action1<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.
  static <T> Observer<T>	Observers.create(Action1<? super T> onNext, Action1<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> Observer<T>	Observers.create(Action1<? super T> onNext, Action1<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.