From 2a84f2eda9cce5790f1de4feb8af160f756b0ad4 Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Tue, 17 Dec 2024 07:15:27 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=AA=E6=94=B6=E5=88=B0=E4=B8=80=E6=9D=A1?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E9=97=AE=E9=A2=98=E7=9A=84=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/extent.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/modules/extent.go b/modules/extent.go index 90e5f82..5d90a11 100644 --- a/modules/extent.go +++ b/modules/extent.go @@ -103,7 +103,7 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi break } cr.CandlesProcessChan <- &cd - break + continue } // 接收到的maX扔到 maX 二次加工流水线 @@ -119,7 +119,7 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi dt = append(dt, mx.AvgVal) mx.Data = dt cr.MaXProcessChan <- &mx - break + continue } // 接收到的tinckerInfo扔到 tickerInfo 二次加工流水线 @@ -132,7 +132,7 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi logrus.Warning("tickerInfo payload unmarshal err: ", err, msg.Payload) } cr.TickerInforocessChan <- &ti - break + continue } // case "seriesInfo": // { @@ -143,7 +143,7 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi // logrus.Warning("seriesInfo payload unmarshal err: ", err, msg.Payload) // } // cr.SeriesChan <- &sei - // break + // continue // } } }