File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
src/main/java/io/reactivex/subjects Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change 34
34
* <p>
35
35
* <pre> {@code
36
36
37
- // observer will receive all events.
38
- BehaviorSubject<Object> subject = BehaviorSubject.create ("default");
37
+ // observer will receive all 4 events (including "default") .
38
+ BehaviorSubject<Object> subject = BehaviorSubject.createDefault ("default");
39
39
subject.subscribe(observer);
40
40
subject.onNext("one");
41
41
subject.onNext("two");
42
42
subject.onNext("three");
43
43
44
44
// observer will receive the "one", "two" and "three" events, but not "zero"
45
- BehaviorSubject<Object> subject = BehaviorSubject.create("default" );
45
+ BehaviorSubject<Object> subject = BehaviorSubject.create();
46
46
subject.onNext("zero");
47
47
subject.onNext("one");
48
48
subject.subscribe(observer);
49
49
subject.onNext("two");
50
50
subject.onNext("three");
51
51
52
52
// observer will receive only onComplete
53
- BehaviorSubject<Object> subject = BehaviorSubject.create("default" );
53
+ BehaviorSubject<Object> subject = BehaviorSubject.create();
54
54
subject.onNext("zero");
55
55
subject.onNext("one");
56
56
subject.onComplete();
57
57
subject.subscribe(observer);
58
58
59
59
// observer will receive only onError
60
- BehaviorSubject<Object> subject = BehaviorSubject.create("default" );
60
+ BehaviorSubject<Object> subject = BehaviorSubject.create();
61
61
subject.onNext("zero");
62
62
subject.onNext("one");
63
63
subject.onError(new RuntimeException("error"));
You can’t perform that action at this time.
0 commit comments