forked from goravel/framework
-
Notifications
You must be signed in to change notification settings - Fork 0
/
test_utils.go
67 lines (49 loc) · 1.32 KB
/
test_utils.go
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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
package event
import (
"errors"
"github.com/mewway/go-laravel/contracts/event"
)
type TestEvent struct{}
func (receiver *TestEvent) Handle(args []event.Arg) ([]event.Arg, error) {
return args, nil
}
type TestEventNoRegister struct{}
func (receiver *TestEventNoRegister) Handle(args []event.Arg) ([]event.Arg, error) {
return args, nil
}
type TestEventHandleError struct{}
func (receiver *TestEventHandleError) Handle(args []event.Arg) ([]event.Arg, error) {
return nil, errors.New("some errors")
}
type TestCancelEvent struct{}
func (receiver *TestCancelEvent) Handle(args []event.Arg) ([]event.Arg, error) {
return args, nil
}
type TestListener struct{}
func (receiver *TestListener) Signature() string {
return "test_listener"
}
func (receiver *TestListener) Queue(args ...any) event.Queue {
return event.Queue{
Enable: false,
Connection: "",
Queue: "",
}
}
func (receiver *TestListener) Handle(args ...any) error {
return nil
}
type TestListenerHandleError struct{}
func (receiver *TestListenerHandleError) Signature() string {
return "test_listener"
}
func (receiver *TestListenerHandleError) Queue(args ...any) event.Queue {
return event.Queue{
Enable: false,
Connection: "",
Queue: "",
}
}
func (receiver *TestListenerHandleError) Handle(args ...any) error {
return errors.New("error")
}