diff options
Diffstat (limited to 'roomserver/internal/input/input.go')
| -rw-r--r-- | roomserver/internal/input/input.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go index 79dc2fe1..2bed0c7f 100644 --- a/roomserver/internal/input/input.go +++ b/roomserver/internal/input/input.go @@ -62,10 +62,10 @@ func (w *inputWorker) start() { for { select { case task := <-w.input: - hooks.Run(hooks.KindNewEventReceived, &task.event.Event) + hooks.Run(hooks.KindNewEventReceived, task.event.Event) _, task.err = w.r.processRoomEvent(task.ctx, task.event) if task.err == nil { - hooks.Run(hooks.KindNewEventPersisted, &task.event.Event) + hooks.Run(hooks.KindNewEventPersisted, task.event.Event) } task.wg.Done() case <-time.After(time.Second * 5): |