|
14 | 14 |
|
15 | 15 | import static rx.functions.Functions.alwaysFalse; |
16 | 16 |
|
17 | | -import java.util.ArrayList; |
18 | | -import java.util.Arrays; |
19 | | -import java.util.Collection; |
20 | | -import java.util.List; |
21 | | -import java.util.Map; |
22 | | -import java.util.NoSuchElementException; |
23 | | -import java.util.concurrent.Future; |
24 | | -import java.util.concurrent.TimeUnit; |
25 | | - |
26 | | -import rx.exceptions.Exceptions; |
27 | | -import rx.exceptions.OnErrorNotImplementedException; |
28 | | -import rx.exceptions.OnErrorThrowable; |
29 | | -import rx.functions.Action0; |
30 | | -import rx.functions.Action1; |
31 | | -import rx.functions.Action2; |
32 | | -import rx.functions.Func0; |
33 | | -import rx.functions.Func1; |
34 | | -import rx.functions.Func2; |
35 | | -import rx.functions.Func3; |
36 | | -import rx.functions.Func4; |
37 | | -import rx.functions.Func5; |
38 | | -import rx.functions.Func6; |
39 | | -import rx.functions.Func7; |
40 | | -import rx.functions.Func8; |
41 | | -import rx.functions.Func9; |
42 | | -import rx.functions.FuncN; |
43 | | -import rx.functions.Function; |
44 | | -import rx.functions.Functions; |
45 | | -import rx.observables.BlockingObservable; |
46 | | -import rx.observables.ConnectableObservable; |
47 | | -import rx.observables.GroupedObservable; |
| 17 | +import java.util.*; |
| 18 | +import java.util.concurrent.*; |
| 19 | + |
| 20 | +import rx.exceptions.*; |
| 21 | +import rx.functions.*; |
| 22 | +import rx.observables.*; |
48 | 23 | import rx.observers.SafeSubscriber; |
49 | | -import rx.operators.OnSubscribeFromIterable; |
50 | | -import rx.operators.OnSubscribeRange; |
51 | | -import rx.operators.OperationDelay; |
52 | | -import rx.operators.OperationTakeLast; |
53 | | -import rx.operators.OperationTakeUntil; |
54 | | -import rx.operators.OperationWindow; |
55 | | -import rx.operators.OperatorAll; |
56 | | -import rx.operators.OperatorAmb; |
57 | | -import rx.operators.OperatorAny; |
58 | | -import rx.operators.OperatorAsObservable; |
59 | | -import rx.operators.OperatorBufferWithSingleObservable; |
60 | | -import rx.operators.OperatorBufferWithSize; |
61 | | -import rx.operators.OperatorBufferWithStartEndObservable; |
62 | | -import rx.operators.OperatorBufferWithTime; |
63 | | -import rx.operators.OperatorCache; |
64 | | -import rx.operators.OperatorCast; |
65 | | -import rx.operators.OperatorCombineLatest; |
66 | | -import rx.operators.OperatorConcat; |
67 | | -import rx.operators.OperatorDebounceWithSelector; |
68 | | -import rx.operators.OperatorDebounceWithTime; |
69 | | -import rx.operators.OperatorDefaultIfEmpty; |
70 | | -import rx.operators.OperatorDefer; |
71 | | -import rx.operators.OperatorDematerialize; |
72 | | -import rx.operators.OperatorDistinct; |
73 | | -import rx.operators.OperatorDistinctUntilChanged; |
74 | | -import rx.operators.OperatorDoOnEach; |
75 | | -import rx.operators.OperatorElementAt; |
76 | | -import rx.operators.OperatorFilter; |
77 | | -import rx.operators.OperatorFinally; |
78 | | -import rx.operators.OperatorGroupBy; |
79 | | -import rx.operators.OperatorGroupByUntil; |
80 | | -import rx.operators.OperatorGroupJoin; |
81 | | -import rx.operators.OperatorJoin; |
82 | | -import rx.operators.OperatorMap; |
83 | | -import rx.operators.OperatorMaterialize; |
84 | | -import rx.operators.OperatorMerge; |
85 | | -import rx.operators.OperatorMergeDelayError; |
86 | | -import rx.operators.OperatorMergeMapPair; |
87 | | -import rx.operators.OperatorMergeMapTransform; |
88 | | -import rx.operators.OperatorMergeMaxConcurrent; |
89 | | -import rx.operators.OperatorMulticast; |
90 | | -import rx.operators.OperatorMulticastSelector; |
91 | | -import rx.operators.OperatorObserveOn; |
92 | | -import rx.operators.OperatorOnErrorFlatMap; |
93 | | -import rx.operators.OperatorOnErrorResumeNextViaFunction; |
94 | | -import rx.operators.OperatorOnErrorResumeNextViaObservable; |
95 | | -import rx.operators.OperatorOnErrorReturn; |
96 | | -import rx.operators.OperatorOnExceptionResumeNextViaObservable; |
97 | | -import rx.operators.OperatorParallel; |
98 | | -import rx.operators.OperatorParallelMerge; |
99 | | -import rx.operators.OperatorPivot; |
100 | | -import rx.operators.OperatorRepeat; |
101 | | -import rx.operators.OperatorReplay; |
102 | | -import rx.operators.OperatorRetry; |
103 | | -import rx.operators.OperatorSampleWithObservable; |
104 | | -import rx.operators.OperatorSampleWithTime; |
105 | | -import rx.operators.OperatorScan; |
106 | | -import rx.operators.OperatorSequenceEqual; |
107 | | -import rx.operators.OperatorSerialize; |
108 | | -import rx.operators.OperatorSingle; |
109 | | -import rx.operators.OperatorSkip; |
110 | | -import rx.operators.OperatorSkipLast; |
111 | | -import rx.operators.OperatorSkipLastTimed; |
112 | | -import rx.operators.OperatorSkipTimed; |
113 | | -import rx.operators.OperatorSkipUntil; |
114 | | -import rx.operators.OperatorSkipWhile; |
115 | | -import rx.operators.OperatorSubscribeOn; |
116 | | -import rx.operators.OperatorSwitch; |
117 | | -import rx.operators.OperatorTake; |
118 | | -import rx.operators.OperatorTakeTimed; |
119 | | -import rx.operators.OperatorTakeWhile; |
120 | | -import rx.operators.OperatorThrottleFirst; |
121 | | -import rx.operators.OperatorTimeInterval; |
122 | | -import rx.operators.OperatorTimeout; |
123 | | -import rx.operators.OperatorTimeoutWithSelector; |
124 | | -import rx.operators.OperatorTimerOnce; |
125 | | -import rx.operators.OperatorTimerPeriodically; |
126 | | -import rx.operators.OperatorTimestamp; |
127 | | -import rx.operators.OperatorToMap; |
128 | | -import rx.operators.OperatorToMultimap; |
129 | | -import rx.operators.OperatorToObservableFuture; |
130 | | -import rx.operators.OperatorToObservableList; |
131 | | -import rx.operators.OperatorToObservableSortedList; |
132 | | -import rx.operators.OperatorUnsubscribeOn; |
133 | | -import rx.operators.OperatorUsing; |
134 | | -import rx.operators.OperatorZip; |
135 | | -import rx.operators.OperatorZipIterable; |
136 | | -import rx.plugins.RxJavaObservableExecutionHook; |
137 | | -import rx.plugins.RxJavaPlugins; |
138 | | -import rx.schedulers.Schedulers; |
139 | | -import rx.schedulers.TimeInterval; |
140 | | -import rx.schedulers.Timestamped; |
141 | | -import rx.subjects.AsyncSubject; |
142 | | -import rx.subjects.BehaviorSubject; |
143 | | -import rx.subjects.PublishSubject; |
144 | | -import rx.subjects.ReplaySubject; |
145 | | -import rx.subjects.Subject; |
| 24 | +import rx.operators.*; |
| 25 | +import rx.plugins.*; |
| 26 | +import rx.schedulers.*; |
| 27 | +import rx.subjects.*; |
146 | 28 | import rx.subscriptions.Subscriptions; |
147 | 29 |
|
148 | 30 | /** |
|
0 commit comments