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…

[image] Restoring Channel#full? Crystal Contrib 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 …

This is what I did: class Channel(T) def full? if queue = @queue return queue.size >= @capacity end !@senders.empty? end def empty? if queue = @queue return queue.empty? end @senders.empty? end end But others have pointed out that it’s not thread safe…

I cannot find the PR for this. What was the reason to remove it. It looks like it was removed around the time MT was merged in.

Channel#empty?/full? gone

Help & Support

bcardiff September 24, 2019, 3:17pm 5

It was removed for the MT support. Let’s follow this discussion in Restoring Channel#full?

Topic		Replies	Views
Restoring Channel#full? Crystal Contrib	10	843	September 24, 2019
Unbuffered channels? Help & Support	12	1049	December 8, 2019
Adding #size to Channel Crystal Contrib	5	840	February 15, 2020
Single-consumer channels Community	3	447	March 3, 2021
Do channels need to be manually closed? Help & Support	5	315	June 16, 2025

Channel#empty?/full? gone

Related topics