diff options
author | Viktor Söderqvist <[email protected]> | 2022-03-07 21:07:35 +0100 |
---|---|---|
committer | Loïc Hoguin <[email protected]> | 2022-03-08 12:02:39 +0100 |
commit | b85a3894f3b8f86e255668a3ca3b1722c5d9d94e (patch) | |
tree | 918934a7814a34d9ac7bee9f1740d51e2fbdc02f /src/gun_raw.erl | |
parent | f9175998687678e227bdd49669e2d83f0648fa57 (diff) | |
download | gun-b85a3894f3b8f86e255668a3ca3b1722c5d9d94e.tar.gz gun-b85a3894f3b8f86e255668a3ca3b1722c5d9d94e.tar.bz2 gun-b85a3894f3b8f86e255668a3ca3b1722c5d9d94e.zip |
Return commands instead of state in remaining callbacks
Diffstat (limited to 'src/gun_raw.erl')
-rw-r--r-- | src/gun_raw.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/gun_raw.erl b/src/gun_raw.erl index 0988d1b..f92c777 100644 --- a/src/gun_raw.erl +++ b/src/gun_raw.erl @@ -44,10 +44,10 @@ init(ReplyTo, Socket, Transport, Opts) -> StreamRef = maps:get(stream_ref, Opts, undefined), {connected_data_only, #raw_state{ref=StreamRef, reply_to=ReplyTo, socket=Socket, transport=Transport}}. -handle(Data, State=#raw_state{ref=StreamRef, reply_to=ReplyTo}, CookieStore, _, EvHandlerState) -> +handle(Data, #raw_state{ref=StreamRef, reply_to=ReplyTo}, CookieStore, _, EvHandlerState) -> %% When we take over the entire connection there is no stream reference. ReplyTo ! {gun_data, self(), StreamRef, nofin, Data}, - {{state, State}, CookieStore, EvHandlerState}. + {[], CookieStore, EvHandlerState}. %% We can always close immediately. closing(_, _, _, EvHandlerState) -> @@ -57,7 +57,7 @@ close(_, _, _, EvHandlerState) -> EvHandlerState. %% @todo Initiate closing on IsFin=fin. -data(State=#raw_state{ref=StreamRef, socket=Socket, transport=Transport}, StreamRef, +data(#raw_state{ref=StreamRef, socket=Socket, transport=Transport}, StreamRef, _ReplyTo, _IsFin, Data, _EvHandler, EvHandlerState) -> Transport:send(Socket, Data), - {State, EvHandlerState}. + {[], EvHandlerState}. |