|
|
@ -23,8 +23,8 @@ func RunWsAndServer(rpcPort, wsPort, prometheusPort int) error {
|
|
|
|
return err
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
hubServer := NewServer(rpcPort, longServer)
|
|
|
|
hubServer := NewServer(rpcPort, longServer)
|
|
|
|
longServer.SetMessageHandler(hubServer.Notification())
|
|
|
|
|
|
|
|
go hubServer.Start()
|
|
|
|
go hubServer.Start()
|
|
|
|
|
|
|
|
longServer.SetMessageHandler(hubServer.Notification())
|
|
|
|
go hubServer.LongConnServer.Run()
|
|
|
|
go hubServer.LongConnServer.Run()
|
|
|
|
wg.Wait()
|
|
|
|
wg.Wait()
|
|
|
|
return nil
|
|
|
|
return nil
|
|
|
|