Building Reactive Applications with WebFlux

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

Mono<User> user = userRepo.findById(id);
Mono<String> name = user.map(User::getName).defaultIfEmpty("anonymous");
Mono.empty(); Mono.just(x); Mono.error(ex);

Flux<Order> recent = orderRepo.findByCreatedAfter(Instant.now().minus(1, HOURS))
  .filter(o -> o.total().compareTo(BigDecimal.TEN) > 0)
  .take(100);

@RestController
@RequestMapping("/api/users")
public class UserApi {
  private final UserRepo repo;
  public UserApi(UserRepo repo) { this.repo = repo; }
  @GetMapping public Flux<User> all() { return repo.findAll(); }
  @GetMapping("/{id}") public Mono<ResponseEntity<User>> one(@PathVariable Long id) {
    return repo.findById(id).map(ResponseEntity::ok).defaultIfEmpty(ResponseEntity.notFound().build());
  }
  @PostMapping public Mono<User> create(@RequestBody Mono<User> body) {
    return body.flatMap(repo::save);
  }
}

spring:
  r2dbc:
    url: r2dbc:postgresql://localhost/app
    username: app
    password: ${DB_PASS}

@GetMapping(value="/events", produces=MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<ServerSentEvent<Quote>> quotes() {
  return Flux.interval(Duration.ofSeconds(1))
    .map(i -> ServerSentEvent.<Quote>builder()
      .id(String.valueOf(i)).event("quote").data(quoteService.next()).build());
}

@WebFluxTest(UserApi.class)
class UserApiTests {
  @Autowired WebTestClient client;
  @MockBean UserRepo repo;
  @Test void list() {
    when(repo.findAll()).thenReturn(Flux.just(new User(1L,"a")));
    client.get().uri("/api/users").exchange()
      .expectStatus().isOk().expectBodyList(User.class).hasSize(1);
  }
}