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