kettle/wkrp/dispatcher_test.go

package wkrp

import (
	"fmt"
	"testing"
	"time"
)

func TestNewDispacher(t *testing.T) {
	d := NewDispacher(16)

	d.Do(func() error {
		time.Sleep(time.Second)
		fmt.Println("did")
		return nil
	})
}