2
0
This commit is contained in:
Lucas Löffel
2018-10-09 14:04:37 +02:00
parent 1986820ec3
commit 112dbdc9f6
+2 -2
View File
@@ -36,7 +36,7 @@ type RecConn struct {
// NonVerbose suppress connecting/reconnecting messages.
NonVerbose bool
// SubscribeHandler fires after the connection successfully establish.
SubscribeHandler func(rc *RecConn) error
SubscribeHandler func() error
mu sync.RWMutex
url string
@@ -299,7 +299,7 @@ func (rc *RecConn) connect() {
return
}
if err := rc.SubscribeHandler(rc); err != nil {
if err := rc.SubscribeHandler(); err != nil {
log.Fatalf("Dial: connect handler failed with %s", err.Error())
}