remove tmp logs && debug output fix
This commit is contained in:
parent
88420d4737
commit
f9d710b126
@ -20,7 +20,7 @@ type DebugExtension struct {
|
|||||||
|
|
||||||
func NewDebugExtension(out io.Writer) *DebugExtension {
|
func NewDebugExtension(out io.Writer) *DebugExtension {
|
||||||
li := log.New(out, "InMsg", 0)
|
li := log.New(out, "InMsg", 0)
|
||||||
lo := log.New(out, "outMsg", 0)
|
lo := log.New(out, "OutMsg", 0)
|
||||||
return &DebugExtension{in: li, out: lo}
|
return &DebugExtension{in: li, out: lo}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -315,10 +315,10 @@ func (w *Websocket) Subscribe(channel string) (*subscription.Subscription, error
|
|||||||
//todo timeout here
|
//todo timeout here
|
||||||
err := <-subRes
|
err := <-subRes
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println(err)
|
//log.Println(err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
log.Println(sub)
|
//log.Println(sub)
|
||||||
return sub, nil
|
return sub, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user