From 74327ff575796fbb68d3406d2eec5c2025626902 Mon Sep 17 00:00:00 2001 From: Jakub Sztandera Date: Sun, 8 Dec 2019 16:00:45 +0100 Subject: [PATCH] Fix mpool sub not unsubbing Resolves #786 License: MIT Signed-off-by: Jakub Sztandera --- chain/messagepool/messagepool.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/chain/messagepool/messagepool.go b/chain/messagepool/messagepool.go index 3f4d64d04..1a827c1bd 100644 --- a/chain/messagepool/messagepool.go +++ b/chain/messagepool/messagepool.go @@ -21,7 +21,6 @@ import ( "github.com/filecoin-project/lotus/api" "github.com/filecoin-project/lotus/build" - "github.com/filecoin-project/lotus/chain" "github.com/filecoin-project/lotus/chain/address" "github.com/filecoin-project/lotus/chain/stmgr" "github.com/filecoin-project/lotus/chain/store" @@ -644,7 +643,7 @@ func (mp *MessagePool) Updates(ctx context.Context) (<-chan api.MpoolUpdate, err sub := mp.changes.Sub(localUpdates) go func() { - defer mp.changes.Unsub(sub, chain.LocalIncoming) + defer mp.changes.Unsub(sub, localUpdates) for { select {