Использование Reactor Context contextWrite/deferContextual ⇐ JAVA

[Anonymous]

Я не мог понять, почему этот простой код не работает.
Я пытаюсь сохранить начальное значение моего реактора Mono и повторно использовать его позже.

Код: Выделить всё

        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();

он ​​заканчивается надписью «Контекст не содержит ключа: INITIAL»? я совершенно неправильно понял эту функцию?


Подробнее здесь: https://stackoverflow.com/questions/764 ... contextual