class Stream 
  def initialize(ts, name)
    @ts = ts 
    @name = name 
    @tail = 0
  end 
  attr_reader :name
  def push(value) 
    @ts.write([name, @tail, value]) 
    @tail += 1
  end 
end