Реактивное программирование приобрело значительную популярность в последние годы благодаря способности эффективно обрабатывать асинхронное и событийно-ориентированное программирование. В Java одной из наиболее широко используемых библиотек реактивного программирования является Project Reactor, который предоставляет богатый набор операторов и утилит для работы с реактивными потоками. В этой статье мы рассмотрим четыре часто используемых метода в Project Reactor: Mono.just(), defer(), fromSupplier() и create(). Мы рассмотрим их различия и предоставим примеры кода, иллюстрирующие их использование.

1. Mono.just():
   Метод Mono.just() — это удобный способ создания Mono, выдающего одно значение. Обычно он используется, когда значение доступно синхронно.

Пример кода:

Mono<String> mono = Mono.just("Hello, World!");
mono.subscribe(System.out::println);

2. Mono.defer():
   Метод Mono.defer() позволяет отложить создание фактического Mono до тех пор, пока на него не подпишется подписчик. Это полезно, когда значение, которое вы хотите передать, недоступно сразу и его необходимо получить асинхронно.

Пример кода:

Mono<String> deferredMono = Mono.defer(() -> {
    // Perform asynchronous operation to obtain the value
    return Mono.just("Hello, World!");
});
deferredMono.subscribe(System.out::println);

3. Mono.fromSupplier():
   Метод Mono.fromSupplier() создает Mono, который выдает одно значение, предоставленное функцией поставщика. Функция поставщика вызывается каждый раз, когда подписчик подписывается на Mono.

Пример кода:

Mono<String> suppliedMono = Mono.fromSupplier(() -> {
    // Perform any necessary computations or data retrieval
    return "Hello, World!";
});
suppliedMono.subscribe(System.out::println);

4. Mono.create():
   Метод Mono.create() обеспечивает наибольшую гибкость среди четырех рассмотренных методов. Он позволяет вам создать Mono с собственной логикой обратного вызова для выдачи значений. Вам необходимо предоставить объект MonoSink, который представляет собой приемник для Mono, и вручную обрабатывать выдачу значений и завершение.

Пример кода:

Mono<String> customMono = Mono.create(sink -> {
    // Emit a value
    sink.success("Hello, World!");
});
customMono.subscribe(System.out::println);

В этой статье мы рассмотрели четыре часто используемых метода в Project Reactor для создания Mono: Mono.just(), defer(), fromSupplier() и create(). Каждый метод имеет свой конкретный вариант использования и обеспечивает разные уровни гибкости. Понимая их различия и зная, когда использовать каждый метод, вы сможете эффективно использовать возможности реактивного программирования на Java.