Sign Up
Log In
Log In
or
Sign Up
Places
All Projects
Status Monitor
Collapse sidebar
home:Ledest:erlang:19
turtle
0025-turtle_subscriber-shrink-handle_message-5....
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
Locations
Projects
Search
Status Monitor
Help
OpenBuildService.org
Documentation
API Documentation
Code of Conduct
Contact
Support
@OBShq
Terms
openSUSE Build Service is sponsored by
The Open Build Service is an
openSUSE project
.
Sign Up
Log In
Places
Places
All Projects
Status Monitor