@@ -166,8 +166,8 @@ stream_body1(Error, _Client) ->
166166
167167-spec stream_body_recv (binary (), # client {})
168168 -> {ok , binary (), # client {}} | {error , term ()}.
169- stream_body_recv (Buffer , Client = # client {parser = # hparser {body_state = {stream , _ , TransferState , _ }}}) ->
170- case recv (Client , TransferState ) of
169+ stream_body_recv (Buffer , Client = # client {parser = # hparser {body_state = {stream , _ , _ , _ }}}) ->
170+ case recv (Client ) of
171171 {ok , Data } ->
172172 stream_body (Data , Client );
173173 {error , Reason } ->
@@ -363,13 +363,6 @@ maybe_close(#client{version={Min,Maj}, headers=Headers, clen=CLen}) ->
363363recv (# client {transport = Transport , socket = Skt , recv_timeout = Timeout }) ->
364364 Transport :recv (Skt , 0 , Timeout ).
365365
366- recv (# client {transport = Transport , socket = Skt , recv_timeout = Timeout }, {_BufSize , undefined }) ->
367- Transport :recv (Skt , 0 , Timeout );
368- recv (# client {transport = Transport , socket = Skt , recv_timeout = Timeout }, {BufSize , ExpectedSize }) when ExpectedSize >= BufSize ->
369- Transport :recv (Skt , ExpectedSize - BufSize , Timeout );
370- recv (# client {transport = Transport , socket = Skt , recv_timeout = Timeout }, {_BufSize , _ExpectedSize }) ->
371- Transport :recv (Skt , 0 , Timeout ).
372-
373366close (# client {socket = nil }= Client ) ->
374367 Client # client {state = closed };
375368close (# client {transport = Transport , socket = Skt }= Client ) ->
0 commit comments