@Internal public class BlockingQueueBroker extends Broker<BlockingQueue<?>>
Broker
for the BlockingQueue
used in
StreamIterationHead
and
StreamIterationTail
for implementing feedback
streams.Modifier and Type | Field and Description |
---|---|
static BlockingQueueBroker |
INSTANCE
Singleton instance.
|
public static final BlockingQueueBroker INSTANCE
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.