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)