Contents

class Stream
  def initialize(&callback)
    @callback = callback
    @closed = false
  end

  def close
    @closed = true
  end

  def each(&front)
    @front = front
    @callback.call(self)
    close
  end

  def <<(data)
    @front.call(data.to_s)
    self
  end

  def closed?
    @closed
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
pubsubstub-0.3.0	lib/pubsubstub/stream.rb
pubsubstub-0.2.2	lib/pubsubstub/stream.rb
pubsubstub-0.2.1	lib/pubsubstub/stream.rb
pubsubstub-0.2.0	lib/pubsubstub/stream.rb
pubsubstub-0.1.3	lib/pubsubstub/stream.rb
pubsubstub-0.1.2	lib/pubsubstub/stream.rb