Merge pull request #502 from spiral/plugin/temporalv2.0.0-beta12

plugin(temporal): Add temporal plugins set to the RR2

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))
+}