File 0025-turtle_subscriber-shrink-handle_message-5.... of Package turtle

Overview Repositories Revisions Requests Users Attributes Meta

File 0025-turtle_subscriber-shrink-handle_message-5.patch of Package turtle

From be0710d12c48f2f4d3159fbacd828c819af20804 Mon Sep 17 00:00:00 2001
From: Led <ledest@gmail.com>
Date: Wed, 28 Nov 2018 18:58:56 +0200
Subject: [PATCH] turtle_subscriber: shrink handle_message/5

---
 src/turtle_subscriber.erl | 14 ++++----------
 1 file changed, 4 insertions(+), 10 deletions(-)

diff --git a/src/turtle_subscriber.erl b/src/turtle_subscriber.erl
index 2f9d5e5..a83e7a0 100644
--- a/src/turtle_subscriber.erl
+++ b/src/turtle_subscriber.erl
@@ -269,20 +269,14 @@ handle_message(Tag, Key,
           end,
     case Res of
         %% Bulk messages
-        L when is_list(L) -> {L, IState};
+        _ when is_list(Res) -> {Res, IState};
         {L, _} when is_list(L) -> Res;
         %% Single messages
-        ack -> {ack, IState};
-        {ack, _} -> Res;
+        _ when Res =:= ack; Res =:= reject; Res =:= remove; Res =:= ok -> {Res, IState};
+        {T, _} when T =:= ack; T =:= reject; T =:= remove; T =:= ok -> Res;
         {reply, CType, Msg} -> {reply, CType, Msg, IState};
         {reply, _, _, _} -> Res;
-        reject -> {reject, IState};
-        {reject, _} -> Res;
-        remove -> {remove, IState};
-        {remove, _} -> Res;
-        {stop, _, _} -> Res;
-        {ok, _} -> Res;
-        ok -> {ok, IState}
+        {stop, _, _} -> Res
     end.
 
 format_amqp_msg(#amqp_msg { payload = Payload, props = Props }) when byte_size(Payload) =< 64 ->
-- 
2.16.4

Places

File 0025-turtle_subscriber-shrink-handle_message-5.patch of Package turtle

Places