Merge pull request #169 from filecoin-project/fix/msg-wait-panic

handle channel closing properly
2019-08-30 11:22:11 -07:00
parent 1bfa0483fa 6144f1af73
commit 7df6417ba8
1 changed files with 4 additions and 1 deletions
@@ -576,7 +576,10 @@ func (cs *ChainStore) WaitForMessage(ctx context.Context, mcid cid.Cid) (cid.Cid

 	for {
 		select {
-		case val := <-tsub:
+		case val, ok := <-tsub:
+			if !ok {
+				return cid.Undef, nil, ctx.Err()
+			}
 			switch val.Type {
 			case HCRevert:
 				continue