File tree 11 files changed +12
-12
lines changed
11 files changed +12
-12
lines changed Original file line number Diff line number Diff line change 116
116
import rx .plugins .RxJavaObservableExecutionHook ;
117
117
import rx .plugins .RxJavaPlugins ;
118
118
import rx .schedulers .Schedulers ;
119
+ import rx .schedulers .TimeInterval ;
120
+ import rx .schedulers .Timestamped ;
119
121
import rx .subjects .AsyncSubject ;
120
122
import rx .subjects .BehaviorSubject ;
121
123
import rx .subjects .PublishSubject ;
122
124
import rx .subjects .ReplaySubject ;
123
125
import rx .subjects .Subject ;
124
126
import rx .subscriptions .Subscriptions ;
125
- import rx .util .TimeInterval ;
126
- import rx .util .Timestamped ;
127
127
import rx .util .functions .Action0 ;
128
128
import rx .util .functions .Action1 ;
129
129
import rx .util .functions .Action2 ;
Original file line number Diff line number Diff line change 32
32
import rx .Scheduler ;
33
33
import rx .Subscriber ;
34
34
import rx .Subscription ;
35
+ import rx .schedulers .Timestamped ;
35
36
import rx .subjects .Subject ;
36
37
import rx .subscriptions .Subscriptions ;
37
- import rx .util .Timestamped ;
38
38
import rx .util .functions .Action0 ;
39
39
import rx .util .functions .Func1 ;
40
40
import rx .util .functions .Functions ;
Original file line number Diff line number Diff line change 28
28
import rx .Observer ;
29
29
import rx .Scheduler ;
30
30
import rx .Subscription ;
31
- import rx .util .Timestamped ;
31
+ import rx .schedulers .Timestamped ;
32
32
33
33
/**
34
34
* Bypasses a specified number of elements at the end of an observable sequence.
Original file line number Diff line number Diff line change 25
25
import rx .Observer ;
26
26
import rx .Scheduler ;
27
27
import rx .Subscription ;
28
- import rx .util .Timestamped ;
28
+ import rx .schedulers .Timestamped ;
29
29
30
30
/**
31
31
* Returns an Observable that emits the last <code>count</code> items emitted by the source
Original file line number Diff line number Diff line change 21
21
import rx .Scheduler ;
22
22
import rx .Subscription ;
23
23
import rx .schedulers .Schedulers ;
24
- import rx .util .TimeInterval ;
24
+ import rx .schedulers .TimeInterval ;
25
25
26
26
/**
27
27
* Records the time interval between consecutive elements in an observable sequence.
Original file line number Diff line number Diff line change 18
18
import rx .Observable .Operator ;
19
19
import rx .Scheduler ;
20
20
import rx .Subscriber ;
21
- import rx .util .Timestamped ;
21
+ import rx .schedulers .Timestamped ;
22
22
23
23
/**
24
24
* Wraps each item emitted by a source Observable in a {@link Timestamped} object.
Original file line number Diff line number Diff line change 13
13
* See the License for the specific language governing permissions and
14
14
* limitations under the License.
15
15
*/
16
- package rx .util ;
16
+ package rx .schedulers ;
17
17
18
18
public class TimeInterval <T > {
19
19
private final long intervalInMilliseconds ;
Original file line number Diff line number Diff line change 13
13
* See the License for the specific language governing permissions and
14
14
* limitations under the License.
15
15
*/
16
- package rx .util ;
16
+ package rx .schedulers ;
17
17
18
18
/**
19
19
* Composite class that takes a value and a timestamp and wraps them.
Original file line number Diff line number Diff line change 28
28
import rx .Observable ;
29
29
import rx .Observer ;
30
30
import rx .schedulers .TestScheduler ;
31
+ import rx .schedulers .TimeInterval ;
31
32
import rx .subjects .PublishSubject ;
32
- import rx .util .TimeInterval ;
33
33
34
34
public class OperationTimeIntervalTest {
35
35
Original file line number Diff line number Diff line change 37
37
import rx .observers .TestObserver ;
38
38
import rx .observers .TestSubscriber ;
39
39
import rx .schedulers .Schedulers ;
40
+ import rx .schedulers .Timestamped ;
40
41
import rx .subjects .PublishSubject ;
41
42
import rx .subscriptions .Subscriptions ;
42
- import rx .util .Timestamped ;
43
43
import rx .util .functions .Action0 ;
44
44
import rx .util .functions .Action1 ;
45
45
import rx .util .functions .Func1 ;
Original file line number Diff line number Diff line change 29
29
import rx .Observable ;
30
30
import rx .Observer ;
31
31
import rx .schedulers .TestScheduler ;
32
+ import rx .schedulers .Timestamped ;
32
33
import rx .subjects .PublishSubject ;
33
- import rx .util .Timestamped ;
34
34
35
35
public class OperatorTimestampTest {
36
36
@ Mock
You can’t perform that action at this time.
0 commit comments