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 Obserable.subscribe 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.
  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.
  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.
  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<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.

• 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	OnSubscribeCache<T> This method has similar behavior to Observable.replay() except that this auto-subscribes to the source Observable rather than returning a connectable Observable.
  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	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	OnSubscribeMulticastSelector<TInput,TIntermediate,TResult> Returns an observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function.
  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	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	OperatorMulticast.connect(Action1<? super Subscription> connection)

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

  Constructor and Description
  	OnSubscribeUsing(Func0<Resource> resourceFactory, Func1<? super Resource,? extends Observable<? extends T>> observableFactory, Action1<? super Resource> dispose)

• Uses of Action1 in rx.internal.util

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

  Modifier and Type	Method and Description
  void	SubscriptionRandomList.forEach(Action1<T> action)

• Uses of Action1 in rx.observables

  Methods in rx.observables with parameters of type Action1

  Modifier and Type	Method and Description
  abstract void	ConnectableObservable.connect(Action1<? super Subscription> connection) Instructs the ConnectableObservable to begin emitting the items from its underlying Observable to its Subscribers.
  void	BlockingObservable.forEach(Action1<? super T> onNext) Invokes a method on each item emitted by this BlockingObservable and blocks until the Observable completes.

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