Java Reactive

import reactor.core.publisher.Mono; class ReactiveJavaTutorial { public static void main(String[] args) { String dataFromMono = getMono().block(); System.out.println(“Data from Mono: ” + dataFromMono); } private static Mono getMono() { return Mono.fromSupplier(() -> { try { Thread.sleep(3000); } catch (InterruptedException e) { e.printStackTrace(); } return “Hello!”; }); } } Output: Data from Mono: Hello! class ReactiveJavaTutorial { public…

import reactor.core.publisher.Mono; class ReactiveJavaTutorial { public static void main(String[] args) { // create a Mono Mono<String> mono = Mono.just(“Hello”); // subscribe to a Mono mono.subscribe(); } } import reactor.core.publisher.Mono; class ReactiveJavaTutorial { public static void main(String[] args) { // create a Mono Mono<String> mono = Mono.just(“Hello”); // subscribe to a Mono mono.subscribe(data -> System.out.println(data)); }…

public static <T> Mono<T> just(T data) import reactor.core.publisher.Mono; class ReactiveJavaTutorial { public static void main(String[] args) { Mono<String> mono = Mono.just(“Hello”); } } import org.reactivestreams.Publisher; import reactor.core.publisher.Mono; class ReactiveJavaTutorial { public static void main(String[] args) { Publisher<String> mono = Mono.just(“Hello”); } } import reactor.core.publisher.Mono; class ReactiveJavaTutorial { public static void main(String[] args) { // will…

<dependency> <groupId>io.projectreactor</groupId> <artifactId>reactor-core</artifactId> <version>3.4.9</version> </dependency> Mono<Integer> mono = Mono.just(1); Flux<Integer> flux = Flux.just(12, 14, 9, 11); Publisher<Integer> mono = Mono.just(2); Publisher<Integer> flux = Flux.just(12, 14, 9, 11); import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import java.util.*; class Test { public static void main(String[] args) { List<Integer> itemsFromMono = new ArrayList<>(); List<Integer> itemsFromFlux = new ArrayList<>(); // Create a…

public interface Publisher<T> { void subscribe(Subscriber<? super T> var1); } public interface Subscriber<T> { void onSubscribe(Subscription var1); void onNext(T var1); void onError(Throwable var1); void onComplete(); } public interface Subscription { void request(long var1); void cancel(); } public interface Processor<T, R> extends Subscriber<T>, Publisher<R> { }