Reaktorverwendung von Context contextWrite / deferContextualJava

Java-Forum
Guest
 Reaktorverwendung von Context contextWrite / deferContextual

Post by Guest »

Ich konnte nicht verstehen, warum dieser einfache Code nicht funktioniert.
Ich versuche, den Anfangswert meines Reaktors Mono zu speichern und ihn später wiederzuverwenden.

Code: Select all

        Mono.just("titi caca")
.flatMap(m -> Mono.just(m).contextWrite(context -> context.put("INITIAL", m)))
.log()
.flatMap(m -> Mono.just(m.toUpperCase()))
.log()
.flatMap(m -> Mono.deferContextual(contextView -> contextView.get("INITIAL")))
.log()
.subscribe();
es endet mit „Kontext enthält keinen Schlüssel: INITIAL“? Habe ich diese Funktion völlig falsch verstanden?

Quick Reply

Change Text Case: 
   
  • Similar Topics
    Replies
    Views
    Last post