Skip to content

Commit 32f9340

Browse files
committedJun 15, 2020
update error wrapping
1 parent b894c14 commit 32f9340

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed
 

‎stream.go

+3-2
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import (
55
"sync"
66

77
"github.com/domonda/errors"
8-
"github.com/domonda/errors/wrap"
8+
"github.com/domonda/go-errs"
99
)
1010

1111
// Stream is an event stream that implements Publisher and Subscribable
@@ -96,6 +96,7 @@ func (stream *Stream) PublishAwait(event interface{}) error {
9696
}
9797

9898
func safelyHandleEvent(handler Handler, event interface{}) (err error) {
99-
defer wrap.RecoverPanicAsResultError(&err, "safelyHandleEvent")
99+
defer errs.RecoverPanicAsErrorWithFuncParams(&err, handler, event)
100+
100101
return handler.HandleEvent(event)
101102
}

‎subscribable.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ func (s *subscribable) Subscribe(handler Handler, eventTypes ...reflect.Type) {
7676
for _, eventType := range eventTypes {
7777
if s.eventTypeHandlers == nil {
7878
s.eventTypeHandlers = map[reflect.Type][]Handler{
79-
eventType: []Handler{handler},
79+
eventType: {handler},
8080
}
8181
} else {
8282
s.eventTypeHandlers[eventType] = append(s.eventTypeHandlers[eventType], handler)

0 commit comments

Comments
 (0)
Please sign in to comment.