summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/gm.erl11
1 files changed, 4 insertions, 7 deletions
diff --git a/src/gm.erl b/src/gm.erl
index 098d84fa..1703864a 100644
--- a/src/gm.erl
+++ b/src/gm.erl
@@ -898,13 +898,10 @@ internal_broadcast(Msg, From, State = #state { self = Self,
State1 = State #state { pub_count = PubCount1,
confirms = Confirms1,
broadcast_buffer = Buffer1 },
- case From =/= none of
- true ->
- handle_callback_result({Result, flush_broadcast_buffer(State1)});
- false ->
- handle_callback_result(
- {Result, State1 #state { broadcast_buffer = Buffer1 }})
- end.
+ handle_callback_result(case From of
+ none -> {Result, State1};
+ _ -> {Result, flush_broadcast_buffer(State1)}
+ end).
flush_broadcast_buffer(State = #state { broadcast_buffer = [] }) ->
State;