summaryrefslogtreecommitdiff
path: root/plugins/temporal/workflow/canceller_test.go
blob: d6e846f88b19e7e50169417427988c303fcf6e62 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
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))
}