From d5d677fc22e7845ec879c37798ba8d86e90abe12 Mon Sep 17 00:00:00 2001 From: guoguangwu Date: Thu, 19 Oct 2023 21:56:39 +0800 Subject: [PATCH] fix: typo --- st/library/dedupe.go | 2 +- st/server/blockmanager.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/st/library/dedupe.go b/st/library/dedupe.go index da6b1e2d..12e0c886 100644 --- a/st/library/dedupe.go +++ b/st/library/dedupe.go @@ -26,7 +26,7 @@ func NewDeDupe() blocks.BlockInterface { // Setup is called once before running the block. We build up the channels and specify what kind of block this is. func (b *DeDupe) Setup() { b.Kind = "Core" - b.Desc = "stores a set of messages as specified by Path, emiting only those it hasn't seen before." + b.Desc = "stores a set of messages as specified by Path, emitting only those it hasn't seen before." b.in = b.InRoute("in") b.inrule = b.InRoute("rule") b.queryrule = b.QueryRoute("rule") diff --git a/st/server/blockmanager.go b/st/server/blockmanager.go index 2010b003..91e305cc 100644 --- a/st/server/blockmanager.go +++ b/st/server/blockmanager.go @@ -301,7 +301,7 @@ func (b *BlockManager) Connect(connInfo *ConnectionInfo) (*ConnectionInfo, error func (b *BlockManager) GetSocket(fromId string) (chan *blocks.Msg, string, error) { _, ok := b.blockMap[fromId] if !ok { - return nil, "", errors.New(fmt.Sprintf("Cannot recieve from block %s: does not exist", fromId)) + return nil, "", errors.New(fmt.Sprintf("Cannot receive from block %s: does not exist", fromId)) } wsChan := make(chan *blocks.Msg)