fix order watchChange routine

BuildOnViction · Apr 29, 2020 · 9130a14 · 9130a14
1 parent 11dd0c8
commit 9130a14
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/services/order.go b/services/order.go
@@ -530,7 +530,17 @@ func (s *OrderService) broadcastRawOrderBookUpdate(orders []*types.Order) {
 	ws.GetRawOrderBookSocket().BroadcastMessage(id, orders)
 }
 
+// WatchChanges wath change record
 func (s *OrderService) WatchChanges() {
+	go func() {
+		for {
+			<-time.After(500 * time.Millisecond)
+			s.processBulkOrders()
+		}
+	}()
+	s.watchChanges()
+}
+func (s *OrderService) watchChanges() {
 	ct, sc, err := s.orderDao.Watch()
 
 	if err != nil {
@@ -545,12 +555,6 @@ func (s *OrderService) WatchChanges() {
 	defer s.WatchChanges()
 
 	ctx := context.Background()
-	go func() {
-		for {
-			<-time.After(500 * time.Millisecond)
-			s.processBulkOrders()
-		}
-	}()
 
 	//Handling change stream in a cycle
 	for {