public static < T > StoppableObservable < T > runAsync ( Scheduler scheduler , final Action2 < ? super Observer < ? super T > , ? super Subscription > action ) { return runAsync ( scheduler , PublishSubject . < T > create ( ) , action ) ; }
Runs the provided action on the given scheduler and allows propagation of multiple events to the observers of the returned StoppableObservable . The action is immediately executed and unobserved values will be lost .