class Emit::ChannelEndWrite

Public Instance Methods

<<(message)
Alias for: call
call(message) click to toggle source
# File lib/emit/channel_end_write.rb, line 6
def call(message)
  @channel.write(message)
end
Also aliased as: <<
retire() click to toggle source
# File lib/emit/channel_end_write.rb, line 11
def retire
  return if @retired

  @retired = true
  @channel.leave_writer
  [:call, :<<, :post_write].each do |sym|
    define_singleton_method(sym) { raise ChannelRetiredException }
  end
end
writer?() click to toggle source
# File lib/emit/channel_end_write.rb, line 21
def writer?
  true
end