Quarkus Reactive

Quarkus Reactive Standards

Mutiny Types

// Uni - 0 or 1 item (like CompletableFuture)
public Uni<User> findById(Long id) {
    return Uni.createFrom().item(() -> repository.findById(id))
        .onFailure().recoverWithItem(User.unknown());
}

// Multi - 0 to N items (like Stream)
public Multi<User> streamAll() {
    return Multi.createFrom().items(repository.findAll().stream())
        .filter(User::isActive);
}

// Transformations
Uni<String> name = findById(1L)
    .map(User::getName)
    .onItem().ifNull().failWith(new NotFoundException());

// Combining
Uni<UserProfile> profile = Uni.combine().all()
    .unis(findUser(id), findOrders(id), findPreferences(id))
    .with((user, orders, prefs) -> new UserProfile(user, orders, prefs));

Reactive REST Endpoints

@Path("/users")
public class UserResource {

    @GET
    @Path("/{id}")
    public Uni<User> get(@PathParam("id") Long id) {
        return userService.findById(id);
    }

    @GET
    @Produces(MediaType.SERVER_SENT_EVENTS)
    public Multi<User> stream() {
        return userService.streamAll();
    }

    @POST
    public Uni<Response> create(CreateUserRequest request) {
        return userService.create(request)
            .map(user -> Response.created(URI.create("/users/" + user.id())).build());
    }
}

References

• Mutiny Patterns - Error handling, timeouts, combining