@@ -73,7 +73,7 @@ public static void main(String[] args) {
7373 subject. onNext(4 );
7474}
7575```
76- Output
76+ [ Output] ( /tests/java/itrx/chapter1/PublishSubjectExample.java )
7777```
78782
79793
@@ -100,7 +100,7 @@ s.onNext(1);
100100s. subscribe(v - > System . out. println(" Late: " + v));
101101s. onNext(2 );
102102```
103- Output
103+ [ Output] ( /tests/java/itrx/chapter1/ReplaySubjectExample.java )
104104```
105105Early:0
106106Early:1
@@ -122,8 +122,7 @@ s.onNext(2);
122122s. subscribe(v - > System . out. println(" Late: " + v));
123123s. onNext(3 );
124124```
125-
126- Output
125+ [ Output] ( /tests/java/itrx/chapter1/ReplaySubjectExample.java )
127126```
128127Late: 1
129128Late: 2
@@ -144,8 +143,7 @@ s.onNext(2);
144143s. subscribe(v - > System . out. println(" Late: " + v));
145144s. onNext(3 );
146145```
147-
148- Output
146+ [ Output] ( /tests/java/itrx/chapter1/ReplaySubjectExample.java )
149147```
150148Late: 1
151149Late: 2
@@ -168,8 +166,7 @@ s.onNext(2);
168166s. subscribe(v - > System . out. println(" Late: " + v));
169167s. onNext(3 );
170168```
171-
172- output
169+ [ Output] ( /tests/java/itrx/chapter1/BehaviorSubjectExample.java )
173170```
174171Late: 2
175172Late: 3
@@ -197,8 +194,7 @@ BehaviorSubject<Integer> s = BehaviorSubject.create(0);
197194s. subscribe(v - > System . out. println(v));
198195s. onNext(1 );
199196```
200-
201- Output
197+ [ Output] ( /tests/java/itrx/chapter1/BehaviorSubjectExample.java )
202198```
2031990
2042001
@@ -218,8 +214,7 @@ s.onNext(1);
218214s. onNext(2 );
219215s. onCompleted();
220216```
221-
222- Output
217+ [ Output] ( /tests/java/itrx/chapter1/AsyncSubjectExample.java )
223218```
2242192
225220```
@@ -238,7 +233,7 @@ s.onCompleted();
238233s. onNext(1 );
239234s. onNext(2 );
240235```
241- Output
236+ [ Output] ( /tests/java/itrx/chapter1/RxContractExample.java )
242237```
2432380
244239```
0 commit comments