summaryrefslogtreecommitdiff
path: root/plugins/temporal/workflow/canceller_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/temporal/workflow/canceller_test.go')
-rw-r--r--plugins/temporal/workflow/canceller_test.go33
1 files changed, 33 insertions, 0 deletions
diff --git a/plugins/temporal/workflow/canceller_test.go b/plugins/temporal/workflow/canceller_test.go
new file mode 100644
index 00000000..d6e846f8
--- /dev/null
+++ b/plugins/temporal/workflow/canceller_test.go
@@ -0,0 +1,33 @@
+package workflow
+
+import (
+ "errors"
+ "testing"
+
+ "github.com/stretchr/testify/assert"
+)
+
+func Test_CancellerNoListeners(t *testing.T) {
+ c := &canceller{}
+
+ assert.NoError(t, c.cancel(1))
+}
+
+func Test_CancellerListenerError(t *testing.T) {
+ c := &canceller{}
+ c.register(1, func() error {
+ return errors.New("failed")
+ })
+
+ assert.Error(t, c.cancel(1))
+}
+
+func Test_CancellerListenerDiscarded(t *testing.T) {
+ c := &canceller{}
+ c.register(1, func() error {
+ return errors.New("failed")
+ })
+
+ c.discard(1)
+ assert.NoError(t, c.cancel(1))
+}