From 6fdf9b433e8e3f0f37f1c6a22859c442f15f961f Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Tue, 17 Dec 2024 07:17:33 +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 | 3 --- 1 file changed, 3 deletions(-) diff --git a/modules/extent.go b/modules/extent.go index 5d90a11..5941535 100644 --- a/modules/extent.go +++ b/modules/extent.go @@ -103,7 +103,6 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi break } cr.CandlesProcessChan <- &cd - continue } // 接收到的maX扔到 maX 二次加工流水线 @@ -119,7 +118,6 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi dt = append(dt, mx.AvgVal) mx.Data = dt cr.MaXProcessChan <- &mx - continue } // 接收到的tinckerInfo扔到 tickerInfo 二次加工流水线 @@ -132,7 +130,6 @@ func LoopSubscribe(cr *core.Core, channelName string, redisConf *core.RedisConfi logrus.Warning("tickerInfo payload unmarshal err: ", err, msg.Payload) } cr.TickerInforocessChan <- &ti - continue } // case "seriesInfo": // {