From 82b95f8605ac6661940e9c8f553af22ac44739ba Mon Sep 17 00:00:00 2001 From: Evstigneev Denis Date: Fri, 20 Dec 2024 21:37:01 +0300 Subject: [PATCH] update call Hooks --- grpc.go | 4 ++-- subscriber.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/grpc.go b/grpc.go index 1e31c01..3b2c1e1 100644 --- a/grpc.go +++ b/grpc.go @@ -420,7 +420,7 @@ func (g *Server) processRequest(ctx context.Context, stream grpc.ServerStream, s return err } - g.opts.Hooks.EachNext(func(hook options.Hook) { + g.opts.Hooks.EachPrev(func(hook options.Hook) { if h, ok := hook.(server.HookHandler); ok { fn = h(fn) } @@ -504,7 +504,7 @@ func (g *Server) processStream(ctx context.Context, stream grpc.ServerStream, se return nil } - opts.Hooks.EachNext(func(hook options.Hook) { + opts.Hooks.EachPrev(func(hook options.Hook) { if h, ok := hook.(server.HookHandler); ok { fn = h(fn) } diff --git a/subscriber.go b/subscriber.go index 4c05e7f..dfea9b8 100644 --- a/subscriber.go +++ b/subscriber.go @@ -197,7 +197,7 @@ func (g *Server) createSubHandler(sb *subscriber, opts server.Options) broker.Ha return nil } - opts.Hooks.EachNext(func(hook options.Hook) { + opts.Hooks.EachPrev(func(hook options.Hook) { if h, ok := hook.(server.HookSubHandler); ok { fn = h(fn) } -- 2.45.2