blob: 3a99ada4a1a9d207baa49bb90cbabf050bd8b491 [file] [log] [blame]
Roman Elizarov0950dfa2018-07-13 10:33:25 +03001public final class kotlinx/coroutines/rx2/RxAwaitKt {
2 public static final fun await (Lio/reactivex/CompletableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
3 public static final fun await (Lio/reactivex/MaybeSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
4 public static final fun await (Lio/reactivex/SingleSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
5 public static final fun awaitFirst (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
6 public static final fun awaitFirstOrDefault (Lio/reactivex/ObservableSource;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
7 public static final fun awaitFirstOrElse (Lio/reactivex/ObservableSource;Lkotlin/jvm/functions/Function0;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
8 public static final fun awaitFirstOrNull (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
9 public static final fun awaitLast (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
10 public static final fun awaitOrDefault (Lio/reactivex/MaybeSource;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
11 public static final fun awaitSingle (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030012}
13
Roman Elizarov0950dfa2018-07-13 10:33:25 +030014public final class kotlinx/coroutines/rx2/RxChannelKt {
15 public static final fun consumeEach (Lio/reactivex/MaybeSource;Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
16 public static final fun consumeEach (Lio/reactivex/ObservableSource;Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
17 public static final fun openSubscription (Lio/reactivex/MaybeSource;)Lkotlinx/coroutines/channels/ReceiveChannel;
Roman Elizarov0950dfa2018-07-13 10:33:25 +030018 public static final fun openSubscription (Lio/reactivex/ObservableSource;)Lkotlinx/coroutines/channels/ReceiveChannel;
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030019}
20
Roman Elizarov0950dfa2018-07-13 10:33:25 +030021public final class kotlinx/coroutines/rx2/RxCompletableKt {
Roman Elizarov0950dfa2018-07-13 10:33:25 +030022 public static final fun rxCompletable (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lio/reactivex/Completable;
Roman Elizarov0950dfa2018-07-13 10:33:25 +030023 public static synthetic fun rxCompletable$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lio/reactivex/Completable;
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030024}
25
Roman Elizarov0950dfa2018-07-13 10:33:25 +030026public final class kotlinx/coroutines/rx2/RxConvertKt {
27 public static final fun asCompletable (Lkotlinx/coroutines/Job;Lkotlin/coroutines/CoroutineContext;)Lio/reactivex/Completable;
28 public static final fun asMaybe (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext;)Lio/reactivex/Maybe;
29 public static final fun asObservable (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/CoroutineContext;)Lio/reactivex/Observable;
30 public static final fun asSingle (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext;)Lio/reactivex/Single;
Vsevolod Tolstopyatov170690f2019-04-09 12:33:57 +030031 public static final fun from (Lkotlinx/coroutines/flow/Flow;)Lio/reactivex/Flowable;
32 public static final fun from (Lkotlinx/coroutines/flow/Flow;)Lio/reactivex/Observable;
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030033}
34
Roman Elizarov0950dfa2018-07-13 10:33:25 +030035public final class kotlinx/coroutines/rx2/RxFlowableKt {
Roman Elizarov0950dfa2018-07-13 10:33:25 +030036 public static final fun rxFlowable (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lio/reactivex/Flowable;
Roman Elizarov0950dfa2018-07-13 10:33:25 +030037 public static synthetic fun rxFlowable$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lio/reactivex/Flowable;
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030038}
39
Roman Elizarov0950dfa2018-07-13 10:33:25 +030040public final class kotlinx/coroutines/rx2/RxMaybeKt {
Roman Elizarov0950dfa2018-07-13 10:33:25 +030041 public static final fun rxMaybe (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lio/reactivex/Maybe;
Roman Elizarov0950dfa2018-07-13 10:33:25 +030042 public static synthetic fun rxMaybe$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lio/reactivex/Maybe;
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030043}
44
Roman Elizarov0950dfa2018-07-13 10:33:25 +030045public final class kotlinx/coroutines/rx2/RxObservableKt {
Roman Elizarov0950dfa2018-07-13 10:33:25 +030046 public static final fun rxObservable (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lio/reactivex/Observable;
Roman Elizarov0950dfa2018-07-13 10:33:25 +030047 public static synthetic fun rxObservable$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lio/reactivex/Observable;
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030048}
49
Roman Elizarov0950dfa2018-07-13 10:33:25 +030050public final class kotlinx/coroutines/rx2/RxSchedulerKt {
51 public static final fun asCoroutineDispatcher (Lio/reactivex/Scheduler;)Lkotlinx/coroutines/rx2/SchedulerCoroutineDispatcher;
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030052}
53
Roman Elizarov0950dfa2018-07-13 10:33:25 +030054public final class kotlinx/coroutines/rx2/RxSingleKt {
Roman Elizarov0950dfa2018-07-13 10:33:25 +030055 public static final fun rxSingle (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lio/reactivex/Single;
Roman Elizarov0950dfa2018-07-13 10:33:25 +030056 public static synthetic fun rxSingle$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lio/reactivex/Single;
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030057}
58
Roman Elizarov0950dfa2018-07-13 10:33:25 +030059public final class kotlinx/coroutines/rx2/SchedulerCoroutineDispatcher : kotlinx/coroutines/CoroutineDispatcher, kotlinx/coroutines/Delay {
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030060 public fun <init> (Lio/reactivex/Scheduler;)V
Roman Elizarov0950dfa2018-07-13 10:33:25 +030061 public fun delay (JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
62 public fun dispatch (Lkotlin/coroutines/CoroutineContext;Ljava/lang/Runnable;)V
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030063 public fun equals (Ljava/lang/Object;)Z
Roman Elizarov27b8f452018-09-20 21:23:41 +030064 public final fun getScheduler ()Lio/reactivex/Scheduler;
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030065 public fun hashCode ()I
Roman Elizarov0950dfa2018-07-13 10:33:25 +030066 public fun invokeOnTimeout (JLjava/lang/Runnable;)Lkotlinx/coroutines/DisposableHandle;
Roman Elizarov0950dfa2018-07-13 10:33:25 +030067 public fun scheduleResumeAfterDelay (JLkotlinx/coroutines/CancellableContinuation;)V
Vsevolod Tolstopyatov74bcc922018-05-03 20:07:54 +030068 public fun toString ()Ljava/lang/String;
69}
70