code: func (b *Broadcaster) Close() error {
  	b.once.Do(func() {
  		close(b.shutdown)
  	})
  
  	<-b.closed
  	return nil
  }
docs: // Close the broadcaster, ensuring that all messages are flushed to the
  // underlying sink before returning.