Method: Emit::Channel#leave_writer

Defined in:
lib/emit/channel.rb

#leave_writer ⇒ Object 



92
93
94
95
96
97
98
99
 
# File 'lib/emit/channel.rb', line 92

def leave_writer
  return if retired?
  @writers -= 1
  if @writers.zero?
    @state = :retired
    @read_queue.each(&:retire)
  end
end