From 4ddd519a6f2c238bf3bef917fbec534b18353d5e Mon Sep 17 00:00:00 2001
From: Paul van Santen <pvansanten@transip.nl>
Date: Mon, 22 Apr 2024 15:17:19 +0200
Subject: [PATCH] Dont forget to instantiate the emitter

---
 job/runner.go      | 3 ++-
 job/runner_test.go | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/job/runner.go b/job/runner.go
index a0a9af0..c882e01 100644
--- a/job/runner.go
+++ b/job/runner.go
@@ -27,6 +27,7 @@ const (
 // NewRunner creates a new job runner
 func NewRunner(ctx context.Context, conf Config, logger *slog.Logger) *Runner {
 	r := &Runner{
+		Emitter:     eventemitter.NewEmitter(false),
 		config:      conf,
 		datasetLock: make(map[string]struct{}),
 		remoteCache: make(map[string]map[string]datasetCache),
@@ -39,7 +40,7 @@ func NewRunner(ctx context.Context, conf Config, logger *slog.Logger) *Runner {
 
 // Runner runs Create, Send and Prune snapshot jobs. Additionally, it can prune filesystems.
 type Runner struct {
-	eventemitter.Emitter
+	*eventemitter.Emitter
 
 	config      Config
 	mapLock     sync.Mutex
diff --git a/job/runner_test.go b/job/runner_test.go
index fc0b78d..1b53b5a 100644
--- a/job/runner_test.go
+++ b/job/runner_test.go
@@ -26,7 +26,7 @@ func runnerTest(t *testing.T, fn func(url string, runner *Runner)) {
 		// Create another zpool as 'source':
 		zfs.TestZPool(testZPool, func() {
 			r := &Runner{
-				Emitter:     *eventemitter.NewEmitter(false),
+				Emitter:     eventemitter.NewEmitter(false),
 				datasetLock: make(map[string]struct{}),
 				remoteCache: make(map[string]map[string]datasetCache),
 				config: Config{