ing
This commit is contained in:
parent
cf875b8b32
commit
a99bf0599a
|
@ -10,12 +10,6 @@ import (
|
||||||
"github.com/gomodule/redigo/redis"
|
"github.com/gomodule/redigo/redis"
|
||||||
)
|
)
|
||||||
|
|
||||||
func New(conn redis.Conn) subscribe.Subscriber {
|
|
||||||
return &Subscribers{
|
|
||||||
Conn: conn,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
type Subscribers struct {
|
type Subscribers struct {
|
||||||
Conn redis.Conn
|
Conn redis.Conn
|
||||||
pubSubConn *redis.PubSubConn
|
pubSubConn *redis.PubSubConn
|
||||||
|
|
Loading…
Reference in New Issue
Block a user