code: function realtimeSimulationPipe(stream) {
    const parser = csv.parse({delimeter: ",", columns: true});
    return Bacon
    .fromEvent(stream.pipe(parser), 'data')
    .bufferingThrottle(1000 / 50)
    .map(v => Object.assign({}, v, { time: new Date().getTime() }))
  }
docs: From a stream of data points @ 50hz, buffer the points and release @ 50hz.