Реактивный код Flux.subscribe () API документация - PullRequest
0 голосов
/ 15 ноября 2018

Некоторые из методов подписки (...) в реактивном ядре класса Flux принимают Runnable как полноценного потребителя.Стоит ли разъяснять в API, что Runnable не используется для создания нового потока.

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html

Сначала я думал, что Runnable используется для создания нового потока.И только когда я начал задаваться вопросом, почему, и проверил базовый LambdaSubscriber, я понял, что run () вызывается напрямую.

Это может спасти новичка (такого как я) от небольшого царапин на голове.

...