Контекст Spring Webflux ReactorJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Контекст Spring Webflux Reactor

Сообщение Anonymous »

В следующем примере test2 должен иметь доступ к значениям контекста из test и test1, но похоже, что этого не происходит. >
Любая информация приветствуется.
Ссылки:
  • http:/ /projectreactor.io/docs/core/release/reference/#context
  • https://github.com/spring-projects/spring -framework/issues/20239 (ранее SPR-15680)
  • https://simonbasle.github.io/2018/02/contextual- logging-with-reactor-context-and-mdc/.
    import reactor.core.publisher.Mono;
    public class Test {

    public static void main(final String[] args) {
    System.out.println(Thread.currentThread().getName()
    + " main "
    + test());
    }

    public static String test() {
    final String key = "message";
    return test1().subscriberContext(ctx -> ctx.put(key, "test")).block();
    }

    public static Mono test1() {
    final String key = "message1";
    return test2().subscriberContext(ctx -> ctx.put(key, "test1 "));
    }

    public static Mono test2() {
    return Mono.just("test2").map(item -> {
    Mono.subscriberContext().map(context -> {
    System.err.println(Thread.currentThread().getName()
    + " test2 "
    + context);
    return context;
    });
    return item;
    });
    }}
Вывод:
main main test2


Подробнее здесь: https://stackoverflow.com/questions/495 ... or-context
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»