From 7eb9bdca873ca7cd14b53ad60600af2a26d2b321 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Mon, 1 Nov 2021 15:33:59 +0000 Subject: [PATCH] fix notes --- notes/handler/notes.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/notes/handler/notes.go b/notes/handler/notes.go index 54286b1..56637ad 100644 --- a/notes/handler/notes.go +++ b/notes/handler/notes.go @@ -69,7 +69,7 @@ func (h *Notes) Create(ctx context.Context, req *pb.CreateRequest, rsp *pb.Creat // return the note in the response rsp.Note = note - go h.Stream.Publish(ctx, &streamPb.PublishRequest{ + h.Stream.Publish(ctx, &streamPb.PublishRequest{ Topic: "notes", Message: newMessage(map[string]interface{}{ "type": "create", @@ -155,7 +155,7 @@ func (h *Notes) Update(ctx context.Context, req *pb.UpdateRequest, rsp *pb.Updat return errors.InternalServerError("notes.update", "Error writing to store: %v", err.Error()) } - go h.Stream.Publish(ctx, &streamPb.PublishRequest{ + h.Stream.Publish(ctx, &streamPb.PublishRequest{ Topic: "notes", Message: newMessage(map[string]interface{}{ "type": "update", @@ -242,7 +242,7 @@ func (h *Notes) Delete(ctx context.Context, req *pb.DeleteRequest, rsp *pb.Delet return errors.InternalServerError("notes.delete", "Failed to delete note") } - go h.Stream.Publish(ctx, &streamPb.PublishRequest{ + h.Stream.Publish(ctx, &streamPb.PublishRequest{ Topic: "notes", Message: newMessage(map[string]interface{}{ "type": "delete",