T
- the type of the input@ParametersAreNonnullByDefault public class ConnectableConsumer<T> extends Object implements Consumer<T>
Consumer
that collects the items it accepts
,
then pass them through to a target Consumer
when connected
.
In this way, you can start accepting
items before the target Consumer
is available.Constructor and Description |
---|
ConnectableConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
accept(T t) |
void |
connect(Consumer<T> consumer)
Process all buffered items, and send all future items to the target
Consumer |
Copyright © 2003–2021 Atlassian. All rights reserved.