code: function realtimeSimulationPipe(stream) {
    const parser = csv.parse({delimeter: ",", columns: true});
    const nodeStream = RxNode
    .fromStream(stream.pipe(parser))
  
    return Observable.zip(nodeStream,
                          Observable.interval(FIFTY_HZ),
                          (data, interval) => data)
    .catch(e => console.log(e))
    .map((v) => Object.assign({},
                              v,
                              {
                                time: new Date().getTime(),
                                x: parseInt(v.x),
                                y: parseInt(v.y),
                                z: parseInt(v.z),
                              }))
  }
docs: From a stream of data points @ 50hz, buffer the points and release @ 50hz.