aboutsummaryrefslogtreecommitdiff
path: root/api
diff options
context:
space:
mode:
Diffstat (limited to 'api')
-rw-r--r--api/markets.go18
1 files changed, 0 insertions, 18 deletions
diff --git a/api/markets.go b/api/markets.go
index 60fb912..119c545 100644
--- a/api/markets.go
+++ b/api/markets.go
@@ -6,24 +6,6 @@ import (
6 6
7var Poloniex *markets.Poloniex 7var Poloniex *markets.Poloniex
8 8
9func OpenMarketsConnection() error {
10 for {
11 err := Poloniex.StartTicker()
12 if err != nil {
13 return err
14 }
15 log.Warn("connection to poloniex stream ended, restarting it...")
16 }
17}
18
19func init() { 9func init() {
20 Poloniex = markets.NewPoloniex() 10 Poloniex = markets.NewPoloniex()
21
22 // We open markets connections in the background as it can take time.
23 go func() {
24 err := OpenMarketsConnection()
25 if err != nil {
26 ErrorChan <- err
27 }
28 }()
29} 11}