code: func (s *TimeoutDropErrChanGen) NewChannelSink() (events.Sink, *events.Channel) {
  	ch := events.NewChannel(0)
  	return timeoutSink{
  		timeout: s.timeout,
  		sink: dropErrClosed{
  			sink: ch,
  		},
  	}, ch
  }
docs: // NewChannelSink creates a new sink chain of timeoutSink->dropErrClosed->Channel