程序包 | 说明 |
---|---|
reactor.core.publisher |
限定符和类型 | 方法和说明 |
---|---|
static <E> DirectProcessor<E> |
DirectProcessor.create()
已过时。
To be removed in 3.5. Closest sink is
Sinks.many().multicast().directBestEffort() ,
except it doesn't terminate overflowing downstreams. |