From 82b95f8605ac6661940e9c8f553af22ac44739ba Mon Sep 17 00:00:00 2001
From: Evstigneev Denis <danteevstigneev@yandex.ru>
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)
 				}