Отмена исключения происходит при подписке на подключаемый горячий источник

Question

Я использую реактор с активной зоной 3.1.4.

Рассмотрим следующий фрагмент кода:

Flux<String> flux = Flux.<String>create(sink -> sink.next("test"))
    .replay(1)
    .refCount();

flux.subscribe(System.out::println);
flux.next().subscribe(System.out::println); // The exception is thrown here!

Ожидаемый результат:

test
test

Фактический вывод:

test
Exception in thread "main" reactor.core.Exceptions$ErrorCallbackNotImplemented: java.util.concurrent.CancellationException: Disconnected
Caused by: java.util.concurrent.CancellationException: Disconnected
    at reactor.core.publisher.FluxReplay$ReplaySubscriber.dispose(FluxReplay.java:1202)
    at reactor.core.publisher.OperatorDisposables.dispose(OperatorDisposables.java:132)
    at reactor.core.publisher.FluxRefCount$RefCountMonitor.innerCancelled(FluxRefCount.java:132)
    at reactor.core.publisher.FluxRefCount$RefCountInner.cancel(FluxRefCount.java:200)
    at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:75)
    at reactor.core.publisher.FluxRefCount$RefCountInner.onNext(FluxRefCount.java:177)
    at reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer.replayNormal(FluxReplay.java:808)
    at reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer.replay(FluxReplay.java:892)
    at reactor.core.publisher.FluxReplay.subscribe(FluxReplay.java:1085)
    at reactor.core.publisher.FluxRefCount$RefCountMonitor.subscribe(FluxRefCount.java:116)
    at reactor.core.publisher.FluxRefCount.subscribe(FluxRefCount.java:77)
    at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
    at reactor.core.publisher.Mono.subscribe(Mono.java:3077)
    at reactor.core.publisher.Mono.subscribeWith(Mono.java:3185)
    at reactor.core.publisher.Mono.subscribe(Mono.java:3071)
    at reactor.core.publisher.Mono.subscribe(Mono.java:3038)
    at reactor.core.publisher.Mono.subscribe(Mono.java:2985)
    at test.Test.main(Test.java:10)

Для меня это ошибка в библиотеке активной зоны реактора. Правильно ли мое утверждение или я что-то упускаю?

Спасибо Стефан

Answer 1

Было подтверждено, что это ошибка. Это фиксируется в активной зоне реактора 3.1.5.