class Stream

Public Class Methods

new(&callback) click to toggle source
# File lib/pubsubstub/stream.rb, line 2
def initialize(&callback)
  @callback = callback
  @closed = false
end

Public Instance Methods

<<(data) click to toggle source
# File lib/pubsubstub/stream.rb, line 17
def <<(data)
  @front.call(data.to_s)
  self
end
close() click to toggle source
# File lib/pubsubstub/stream.rb, line 7
def close
  @closed = true
end
closed?() click to toggle source
# File lib/pubsubstub/stream.rb, line 22
def closed?
  @closed
end
each(&front) click to toggle source
# File lib/pubsubstub/stream.rb, line 11
def each(&front)
  @front = front
  @callback.call(self)
  close
end