Skip to content
Discussion options

You must be logged in to vote

Ended up using expect { |b| queue.each(&b) }.to yield_successive_args(...). Also had to close the queue in order to prevent Async::Queue#each from blocking while dequeueing.

Replies: 1 comment

Comment options

You must be logged in to vote
0 replies
Answer selected by postmodern
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Category
Q&A
Labels
None yet
1 participant