Method: Emit::Channel#leave_reader

Defined in:
lib/emit/channel.rb

#leave_reader ⇒ Object 



83
84
85
86
87
88
89
90
 
# File 'lib/emit/channel.rb', line 83

def leave_reader
  return if retired?
  @readers -= 1
  if @readers.zero?
    @state = :retired
    @write_queue.each(&:retire)
  end
end