WorkQueueProcessor не запускается с ошибкой «Небезопасно доступно» - PullRequest
Новая
       11

WorkQueueProcessor не запускается с ошибкой «Небезопасно доступно»

0 голосов
/ 11 сентября 2018

Я экспериментирую с WorkQueueProcessor из реактора, это мой простой тест: 

WorkQueueProcessor.Builder<String> topicProcessorBuilder = WorkQueueProcessor.builder();
    WorkQueueProcessor<String> hotSource = topicProcessorBuilder
      .build();

    Flux<String> hotFlux = hotSource.publish()
      .autoConnect()
      .map(String::toUpperCase);


    hotFlux.subscribe(d -> System.out.println(Thread.currentThread() + " Subscriber 1 to Hot Source: " + d));

    hotSource.onNext("ram");
    hotSource.onNext("sam");

    hotFlux.subscribe(d -> System.out.println(Thread.currentThread() + " Subscriber 2 to Hot Source: " + d));

    hotSource.onNext("dam");
    hotSource.onNext("lam");
    hotSource.onComplete();

И на выходе я вижу это:

20: 25: 46.226 [main] DEBUG pipeline.util.Loggers $ LoggerFactory - Использование каркаса ведения журналов Slf4j 20: 25: 46.246 [main] DEBUG реактор.core.publisher.UnsafeSupport - запуск init UnsafeSupport в Java 1.8 20: 25: 46.248 [main] DEBUG реактор.core.publisher.UnsafeSupport - доступен небезопасный

Как я могу исправить эту ошибку и выполнить ее, как ожидалось?Заранее спасибо.

...