@@ -29,9 +29,9 @@ class KitchenService {
29
29
Flux <Dish > getDishes () {
30
30
// You could model a ChefService, but let's just
31
31
// hard code some tasty dishes.
32
- return Flux .just ( //
33
- new Dish ("Sesame chicken" ), //
34
- new Dish ("Lo mein noodles, plain" ), //
32
+ return Flux .just (
33
+ new Dish ("Sesame chicken" ),
34
+ new Dish ("Lo mein noodles, plain" ),
35
35
new Dish ("Sweet & sour beef" ));
36
36
}
37
37
}
@@ -47,7 +47,7 @@ class SimpleServer {
47
47
}
48
48
49
49
Flux <Dish > doingMyJob () {
50
- return this .kitchen .getDishes () //
50
+ return this .kitchen .getDishes ()
51
51
.map (dish -> this .deliver (dish ));
52
52
}
53
53
@@ -69,10 +69,10 @@ class PoliteServer {
69
69
}
70
70
71
71
Flux <Dish > doingMyJob () {
72
- return this .kitchen .getDishes () //
73
- .doOnNext (dish -> System .out .println ("Thank you for " + dish + "!" )) //
74
- .doOnError (error -> System .out .println ("So sorry about " + error .getMessage ())) //
75
- .doOnComplete (() -> System .out .println ("Thanks for all your hard work!" )) //
72
+ return this .kitchen .getDishes ()
73
+ .doOnNext (dish -> System .out .println ("Thank you for " + dish + "!" ))
74
+ .doOnError (error -> System .out .println ("So sorry about " + error .getMessage ()))
75
+ .doOnComplete (() -> System .out .println ("Thanks for all your hard work!" ))
76
76
.map (this ::deliver );
77
77
}
78
78
@@ -93,12 +93,12 @@ class BusyServer {
93
93
94
94
Flux <Dish > doingMyJob () {
95
95
// tag::multiple-side-effects[]
96
- return this .kitchen .getDishes () //
97
- .doOnNext (dish -> { //
98
- System .out .println ("Thank you for " + dish + "!" ); //
99
- System .out .println ("Marking the ticket as done." ); //
100
- System .out .println ("Grabbing some silverware." ); //
101
- }) //
96
+ return this .kitchen .getDishes ()
97
+ .doOnNext (dish -> {
98
+ System .out .println ("Thank you for " + dish + "!" );
99
+ System .out .println ("Marking the ticket as done." );
100
+ System .out .println ("Grabbing some silverware." );
101
+ })
102
102
.map (this ::deliver );
103
103
// end::multiple-side-effects[]
104
104
}
@@ -119,10 +119,10 @@ class BusyServer2 {
119
119
120
120
Flux <Dish > doingMyJob () {
121
121
// tag::multiple-side-effects2[]
122
- return this .kitchen .getDishes () //
123
- .doOnNext (dish -> System .out .println ("Thank you for " + dish + "!" )) //
124
- .doOnNext (dish -> System .out .println ("Marking the ticket as done." )) //
125
- .doOnNext (dish -> System .out .println ("Grabbing some silverware." )) //
122
+ return this .kitchen .getDishes ()
123
+ .doOnNext (dish -> System .out .println ("Thank you for " + dish + "!" ))
124
+ .doOnNext (dish -> System .out .println ("Marking the ticket as done." ))
125
+ .doOnNext (dish -> System .out .println ("Grabbing some silverware." ))
126
126
.map (this ::deliver );
127
127
// end::multiple-side-effects2[]
128
128
}
@@ -153,9 +153,9 @@ public void setDelivered(boolean delivered) {
153
153
154
154
@ Override
155
155
public String toString () {
156
- return "Dish{" + //
157
- "description='" + description + '\'' + //
158
- ", delivered=" + delivered + //
156
+ return "Dish{" +
157
+ "description='" + description + '\'' +
158
+ ", delivered=" + delivered +
159
159
'}' ;
160
160
}
161
161
}
@@ -170,7 +170,7 @@ public static void main(String... args) {
170
170
171
171
server .doingMyJob () //
172
172
.subscribe ( //
173
- dish -> System .out .println ("Consuming " + dish ), //
173
+ dish -> System .out .println ("Consuming " + dish ),
174
174
throwable -> System .err .println (throwable ));
175
175
}
176
176
}
0 commit comments