SpringWebFlux Mono Sınıfı

Giriş
Şu satırı dahil ederiz

import reactor.core.publisher.Mono;

Bu sınıf aslında Spring'e ait değil. Project Reactor'a ait. Soyut bir sınıf. [0-1) arası nesne üretir. Project Reactor Java 8+ ile kullanılır. Açıklaması şöyle.

Reactor on the other hand is Java 8+ only, so it can make full use of the new Java 8 native classes. Since Spring 5.0 is also Java 8+ only, that means Reactor has the edge in this regard.

Bu Sınıf Niçin Lazım ?
Açıklaması şöyle. Reactive Stream tiplerinin yetersiz kaldığı düşünülerek tasarlanmış. Reactive Stream'deki Publisher arayüzünü gerçekleştirir.

The Reactive Streams types are not enough; you’ll need higher order implementations to support operations like filtering and transformation. The Reactor project is a good choice here; it builds on top of the Reactive Streams specification. It provides two specializations of  Publisher<T>.

The first, Flux<T>, is a Publisher that produces zero or more values. It’s unbounded. The second, Mono<T>, is a Publisher<T> that produces zero or one value. They’re both publishers and you can treat them that way, but they go much further than the Reactive Streams specification. They both provide operators, ways to process a stream of values. Reactor types compose nicely - the output of one thing can be the input to another and if a type needs to work with other streams of data, they rely upon Publisher<T> instances.

Both Mono<T> and Flux<T> implement Publisher<T>; our recommendation is that your methods accept Publisher<T> instances but return Flux<T> or Mono<T> to help the client distinguish the kind of data its being given.

block metodu
Açıklaması şöyle

to retrieve object from mono you have to block

Örnek
Şöyle yaparız.

Mono.just(new Employee().setName("Kill"))
    .switchIfEmpty(Mono.defer(() -> Mono.just(new Employee("Bill"))))
    .block()
    .getName();

doOnError metodu - Consumer
Şöyle yaparız.

Mono<AuthorizeResponse> result = ...
response = result.doOnError(e -> {throw new RuntimeException(e);})
                 .block();

error metodu

Şöyle yaparız

@Transactional
public Mono<Store> addStore(Store store) {
  if (store.isValid()) {
    final Mono<Store> result = storePort.addStore(store);
    return result;
  }
  return Mono.error(InvalidAttributesException::new);
}

flatMap metodu

Mono.flatMap metodu yazısına taşıdım

flatMapMany metodu

Mono nesnesini Flux nesnesine çevirir. Yani 1 nesneyi OneToMany haline getirir.

fromCallable metodu

Mono.fromCallable metodu yazısına taşıdım

fromRunnable metodu

Örnek

Şöyle yaparız

Mono.fromRunnable(() -> System.out.println("Hello"))
        .subscribe(
                i -> System.out.println("Received :: " + i),
                err -> System.out.println("Error :: " + err),
                () -> System.out.println("Successfully completed"));

//Output
Hello
Successfully completed  

fromSupplier metodu
Şöyle yaparız. Supplier verilen veriyi işler ve bir sonuç döner. Bu döndürülen Mono nesnesinin sonucunu almak için ya block() metodu ya da subscribe() metodu çağrılır.

public Mono<Integer> nonBlockingSum(Integer arr[])
  throws InterruptedException {

  Mono<Integer> m = Mono.fromSupplier(() ->this.computationService.getSum(arr))
                        .subscribeOn(this.scheduler);
  return m;
}

justmetodu

Mono.just metodu yazısına taşıdım

justOrEmpty metodu

Örnek

Şöyle yaparız

Mono<String> publisher = Mono.justOrEmpy("My first publisher");

onErrorResume metodu

Mono.onErrorResume metodu yazısına taşıdım

then metodu

Mono.then metodu yazısına taşıdım

thenReturn metodu

Mono.thenReturn metodu yazısına taşıdım

switchIfEmpty metodu

Mono.switchIfEmpty metodu yazısına taşıdım