Support for Processor
ldaley opened this issue · 1 comments
ldaley commented
Do we want to provide Processor impls?
If so, I think it would look something like this…
public static Processor<T, T> backpressureBufferingProcessor(Subject<T, T> subject) {}
public static Processor<T, T> backpressureDroppingProcessor(Subject<T, T> subject) {}
ldaley commented
I'm going to close this, as I can't really convince myself there's a need for it.
Can always reopen if someone has a convincing argument.