Method ChanSubscribe

js.go:1539–1541

ChanSubscribe creates channel based Subscription. Using ChanSubscribe without buffered capacity is not recommended since it will be prone to dropping messages with a slow consumer error. Make sure to give the channel enough capacity to handle bursts in traffic, for example other Subscribe APIs use

(subj string, ch chan *Msg, opts ...SubOpt)

// capacity to handle bursts in traffic, for example other Subscribe APIs use a default of 512k capacity in comparison.
// See important note in Subscribe()
func (js *js) ChanSubscribe(subj string, ch chan *Msg, opts ...SubOpt) (*Subscription, error) {
	return js.subscribe(subj, _EMPTY_, nil, ch, false, false, opts)
}

// ChanQueueSubscribe creates channel based Subscription with a queue group.
// See important note in QueueSubscribe()