code: func newBpsLoop(dst *uint64) SinkFunc {
  	fn := func() chan<- Report {
  		sink := make(chan Report)
  		go bpsLoop(sink, dst)
  		return sink
  	}
  
  	return fn
  }
docs: // newBpsLoop returns a sink that monitors and stores throughput.