func()

in bayeux.go [323:339]


func (b *Bayeux) Channel(ctx context.Context, out chan MaybeMsg, r string, creds Credentials, channel string) chan MaybeMsg {
	b.creds = creds
	err := b.getClientID(ctx)
	if err != nil {
		out <- MaybeMsg{Err: err}
		close(out)
		return out
	}
	err = b.subscribe(ctx, channel, r)
	if err != nil {
		out <- MaybeMsg{Err: err}
		close(out)
		return out
	}
	c := b.connect(ctx, out)
	return c
}