Added closing of test server in forward tests

Signed-off-by: Corbin Phelps <[email protected]>
observIQ · Feb 15, 2022 · 7a25f65 · 7a25f65
1 parent 09d20a0
commit 7a25f65
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/operator/builtin/output/forward/forward_test.go b/operator/builtin/output/forward/forward_test.go
@@ -23,6 +23,7 @@ func TestForwardOutput(t *testing.T) {
 		body, _ := ioutil.ReadAll(req.Body)
 		received <- body
 	}))
+	defer srv.Close()
 
 	cfg := NewForwardOutputConfig("test")
 	memoryCfg := buffer.NewMemoryBufferConfig()
@@ -67,6 +68,7 @@ func TestFlushBufferOnClose(t *testing.T) {
 		body, _ := ioutil.ReadAll(req.Body)
 		received <- body
 	}))
+	defer srv.Close()
 
 	cfg.Address = srv.URL
 	ops, err := cfg.Build((testutil.NewBuildContext(t)))