Improve tests and fix bugs (#2)

Author: thenorthnate

middleware_test.go

@@ -2,24 +2,23 @@ package buzz
 
 import (
 	"context"
-	"errors"
 	"testing"
 )
 
 func TestRecoveryMiddleware(t *testing.T) {
-	bee := NewWorker(&mockTask{
+	worker := NewWorker(&mockTask{
 		dofunc: func(ctx context.Context) error {
-			return errors.New("darn")
+			panic("darn")
 		},
 	}).Use(RecoveryMiddleware)
-	chain := bee.assembleCallChain()
+	chain := worker.assembleCallChain()
 	if chain.exec == nil {
 		t.Fatal("exec was supposed to be defined but was nil instead")
 	}
 	if chain.next == nil {
 		t.Fatal("chain.next was not supposed to be nil")
 	}
-	if err := bee.runChainOnce(context.Background(), chain); err == nil {
+	if err := worker.runChainOnce(context.Background(), chain); err == nil {
 		t.Fatal("runChainOnce was supposed to return an error but did not")
 	}
 }

worker.go

@@ -65,9 +65,7 @@ func (w *Worker) run(block *sync.WaitGroup) {
 		case <-ctx.Done():
 			return
 		default:
-			if err := w.runChainOnce(ctx, callChain); err != nil {
-				return
-			}
+			_ = w.runChainOnce(ctx, callChain)
 		}
 	}
 }