code: func (queue *BufferedQueue) FlushBuffer() {
  	flushing := make(chan bool, 1)
  	queue.flushStatus <- flushing
  	queue.flushCommand <- true
  	<-flushing
  	return
  }
docs: // FlushBuffer tells the background writer to flush the buffer to redis