This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 70ac565ea71f247fbe545489a5916ed058f4ddac
Merge: abe3aa7 d0253ed
Author: Lukasz Cwik <lukec...@gmail.com>
AuthorDate: Mon Oct 18 16:26:01 2021 -0700
[BEAM-13015] Implement a simplified cancellable blocking queue with similar
semantics to ArrayBlockingQueue.
.../org/apache/beam/sdk/fn/CancellableQueue.java | 145 ++++++++++++++
.../apache/beam/sdk/fn/CancellableQueueTest.java | 213 +++++++++++++++++++++
2 files changed, 358 insertions(+)
