We have an existing code base that relies on Channel#full? and Channel#empty? but those methods are gone in 0.31.0. For example, in one part of the code we only want to fsync a file when the incoming queue is empty: loop do file.write_bytes ch.receive file.fsync if ch.empty? end Is there a tec…

Channel#empty?/full? gone

stronny September 24, 2019, 12:35pm 2

I noticed that in 0.31 Channel#full? was removed with all the channel changes. I use it, so I had to get it working again. class Channel(T) def full? if queue = @queue return queue.size >= @capacity end !@senders.empty? end end require "spec" describe Channel do describe "full?" do it "returns true if the channel is full (unbuffered)" do ch = Channel(Nil).new ch.full?.should eq false spawn do ch.full?.should eq true ch.receive …

show post in topic

Home
Categories
Guidelines
Terms of Service
Privacy Policy

Powered by Discourse, best viewed with JavaScript enabled