T
- The type of the subjectsEX
- The exception that the producers may throwpublic class WyeConsumer<T,EX extends Throwable> extends Object implements RunnableWhichThrows<EX>
run()
Constructor and Description |
---|
WyeConsumer(ConsumerWhichThrows<? super T,EX> target) |
Modifier and Type | Method and Description |
---|---|
Consumer<T> |
newConsumer(int capacity) |
void |
run()
Copies the subjects that are sent to the
Consumer that was returned by the first call to newConsumer(int) up to, but not including, the first null reference, to the target
consumer, then the objects that are sent to the Consumer that was returned by the second call to newConsumer(int) , and so forth. |
public WyeConsumer(ConsumerWhichThrows<? super T,EX> target)
run()
public void run() throws EX extends Throwable
Consumer
that was returned by the first call to newConsumer(int)
up to, but not including, the first null
reference, to the target
consumer, then the objects that are sent to the Consumer
that was returned by the second call to newConsumer(int)
, and so forth.Copyright © 2018 Arno Unkrig. All rights reserved.