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.

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

Channel#empty?/full? gone

Help & Support

stronny September 24, 2019, 12:35pm 2

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	841	February 15, 2020
Single-consumer channels Community	3	448	March 3, 2021
Do channels need to be manually closed? Help & Support	5	317	June 16, 2025

Channel#empty?/full? gone

Related topics