From 26821a08c1c5a00f4d1b583fb714ef73ce83c76d Mon Sep 17 00:00:00 2001 From: Ali Najafizadeh Date: Mon, 20 May 2024 13:15:19 -0400 Subject: [PATCH] Clean up code --- request_reply_test.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/request_reply_test.go b/request_reply_test.go index 1e84d47..6af7afa 100644 --- a/request_reply_test.go +++ b/request_reply_test.go @@ -22,7 +22,9 @@ func TestRequestReply(t *testing.T) { Result int } - bus.Reply(context.TODO(), client, "func.div", func(ctx context.Context, in json.RawMessage) (resp any, err error) { + subject := "func.div" + + bus.Reply(context.TODO(), client, subject, func(ctx context.Context, in json.RawMessage) (resp any, err error) { req := &Req{} err = json.Unmarshal(in, req) if err != nil { @@ -36,7 +38,7 @@ func TestRequestReply(t *testing.T) { return &Resp{Result: req.A / req.B}, nil }) - fn := bus.Request(client, "func.div") + fn := bus.Request(client, subject) req := &Req{A: 4, B: 2} resp := &Resp{}