Package org.apache.flink.connector.base.source.reader.synchronization

Class Summary

Class	Description
FutureCompletingBlockingQueue<T>	A custom implementation of blocking queue in combination with a CompletableFuture that is used in the hand-over of data from a producing thread to a consuming thread.