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
}