Skip to content

Commit a504814

Browse files
committed
fix indentation
1 parent 9719019 commit a504814

2 files changed

Lines changed: 40 additions & 40 deletions

File tree

documentation/modules/ROOT/pages/14_reactive.adoc

Lines changed: 29 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -301,10 +301,10 @@ Open `BeerService` interface and add the following method to get a beer:
301301
[.console-input]
302302
[source,java]
303303
----
304-
@GET
305-
@Path("/beers/{id}")
306-
@Produces(MediaType.APPLICATION_JSON)
307-
Uni<JsonArray> getBeer(@PathParam("id") int id);
304+
@GET
305+
@Path("/beers/{id}")
306+
@Produces(MediaType.APPLICATION_JSON)
307+
Uni<JsonArray> getBeer(@PathParam("id") int id);
308308
----
309309

310310
=== Modify BeerResource
@@ -314,35 +314,35 @@ Open `BeerResource` class and add the following methods to do in parallel the bo
314314
[.console-input]
315315
[source,java]
316316
----
317-
@GET
318-
@Path("/{beerA}/{beerB}")
319-
public Uni<JsonValue> compare(@PathParam("beerA") int beerA, @PathParam("beerB") int beerB) {
320-
Uni<JsonArray> beer1 = beerService.getBeer(beerA); // <1>
321-
Uni<JsonArray> beer2 = beerService.getBeer(beerB); // <2>
322-
323-
return Uni.combine()
324-
.all()
325-
.unis(beer1, beer2) // <3>
326-
.with((b1, b2) -> this.compare(b1, b2)); // <4>
327-
}
317+
@GET
318+
@Path("/{beerA}/{beerB}")
319+
public Uni<JsonValue> compare(@PathParam("beerA") int beerA, @PathParam("beerB") int beerB) {
320+
Uni<JsonArray> beer1 = beerService.getBeer(beerA);
321+
Uni<JsonArray> beer2 = beerService.getBeer(beerB);
322+
323+
return Uni.combine()
324+
.all()
325+
.unis(beer1, beer2)
326+
.with((b1, b2) -> this.compare(b1, b2));
327+
}
328328
329-
private JsonValue compare(JsonArray beerA, JsonArray beerB) {
330-
JsonObject source = beerA.get(0).asJsonObject();
331-
JsonObject target = beerB.get(0).asJsonObject();
329+
private JsonValue compare(JsonArray beerA, JsonArray beerB) {
330+
JsonObject source = beerA.get(0).asJsonObject();
331+
JsonObject target = beerB.get(0).asJsonObject();
332332
333-
String beerAName = source.getString("name");
334-
String beerBName = target.getString("name");
333+
String beerAName = source.getString("name");
334+
String beerBName = target.getString("name");
335335
336-
double beerAAbv = source.getJsonNumber("abv").doubleValue();
337-
double beerBAbv = target.getJsonNumber("abv").doubleValue();
336+
double beerAAbv = source.getJsonNumber("abv").doubleValue();
337+
double beerBAbv = target.getJsonNumber("abv").doubleValue();
338338
339-
return Json.createObjectBuilder()
340-
.add("source-name", beerAName)
341-
.add("target-name", beerBName)
342-
.add("source-abv", beerAAbv)
343-
.add("target-abv", beerBAbv)
344-
.build();
345-
}
339+
return Json.createObjectBuilder()
340+
.add("source-name", beerAName)
341+
.add("target-name", beerBName)
342+
.add("source-abv", beerAAbv)
343+
.add("target-abv", beerBAbv)
344+
.build();
345+
}
346346
----
347347
<1> Executes request for first beer
348348
<2> Executes request for second beer

documentation/modules/ROOT/pages/15_reactive-messaging.adoc

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -60,17 +60,17 @@ And the business code:
6060
[.console-input]
6161
[source,java]
6262
----
63-
@Channel("beers")
64-
Emitter<JsonObject> emitter;
65-
66-
@GET
67-
@Path("/emit/{beer}")
68-
public Response emitBeer(@PathParam("beer") int beerId) {
69-
beerService.getBeer(beerId) // <1>
70-
.map(beers -> beers.get(0).asJsonObject()) // <2>
71-
.subscribe().with(emitter::send); // <3>
72-
return Response.ok().build(); // <4>
73-
}
63+
@Channel("beers")
64+
Emitter<JsonObject> emitter;
65+
66+
@GET
67+
@Path("/emit/{beer}")
68+
public Response emitBeer(@PathParam("beer") int beerId) {
69+
beerService.getBeer(beerId) // <1>
70+
.map(beers -> beers.get(0).asJsonObject()) // <2>
71+
.subscribe().with(emitter::send); // <3>
72+
return Response.ok().build(); // <4>
73+
}
7474
----
7575
<1> Finds the beer
7676
<2> Gets the first beer

0 commit comments

Comments
 (0)