class RDStream 
  def initialize(ts, name)
    @ts = ts 
    @name = name 
    @head = 0
  end
  
  def read 
    tuple = @ts.read([@name, @head, nil]) 
    @head += 1 
    return tuple[2]
  end 
end