File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
app/src/main/java/com/rxjava2/android/samples/ui/operators Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -67,15 +67,15 @@ private Observable<Integer> getObservable() {
67
67
public void subscribe (ObservableEmitter <Integer > emitter ) throws Exception {
68
68
// send events with simulated time wait
69
69
Thread .sleep (0 );
70
- emitter .onNext (1 ); // skip
71
- emitter .onNext (2 ); // deliver
70
+ emitter .onNext (1 ); // deliver
71
+ emitter .onNext (2 ); // skip
72
72
Thread .sleep (505 );
73
- emitter .onNext (3 ); // skip
73
+ emitter .onNext (3 ); // deliver
74
74
Thread .sleep (99 );
75
75
emitter .onNext (4 ); // skip
76
76
Thread .sleep (100 );
77
77
emitter .onNext (5 ); // skip
78
- emitter .onNext (6 ); // deliver
78
+ emitter .onNext (6 ); // skip
79
79
Thread .sleep (305 );
80
80
emitter .onNext (7 ); // deliver
81
81
Thread .sleep (510 );
You can’t perform that action at this time.
0 commit comments