diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 5c0dee7320..ce3d879cf4 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -197,7 +197,7 @@ init(Parent, ChannelSupSupPid, Collector) -> end. system_continue(Parent, Deb, State) -> - ?MODULE:mainloop(Deb, State = #v1{parent = Parent}). + ?MODULE:mainloop(Deb, State#v1{parent = Parent}). system_terminate(Reason, _Parent, _Deb, _State) -> exit(Reason). @@ -333,8 +333,7 @@ mainloop(Deb, State = #v1{parent = Parent, sock= Sock, recv_ref = Ref}) -> {State1, Callback1, Length1} = handle_input(State#v1.callback, Data, State#v1{recv_ref = none}), - mainloop(Deb, - switch_callback(State1, Callback1, Length1)); + mainloop(Deb, switch_callback(State1, Callback1, Length1)); {inet_async, Sock, Ref, {error, closed}} -> if State#v1.connection_state =:= closed -> State; |