code: func NewNotifier(send func([]byte) (int, error)) Notifier {
  	n := &notifier{}
  	n.ctx, n.cancel = context.WithCancel(context.Background())
  	n.send = send
  	// n.maxlen = cap
  	return n
  }
docs: // NewNotifier ...