diff --git a/pubsub.go b/pubsub.go index 03b0156..30362cf 100644 --- a/pubsub.go +++ b/pubsub.go @@ -309,9 +309,10 @@ func (c *PubSub) newMessage(reply interface{}) (interface{}, error) { case []interface{}: switch kind := reply[0].(string); kind { case "subscribe", "unsubscribe", "psubscribe", "punsubscribe": + channel, _ := reply[1].(string) return &Subscription{ Kind: kind, - Channel: reply[1].(string), + Channel: channel, Count: int(reply[2].(int64)), }, nil case "message":