diff options
| author | Masatake Daimon <[email protected]> | 2013-05-17 13:01:20 +0900 |
|---|---|---|
| committer | Masatake Daimon <[email protected]> | 2013-05-20 16:36:51 +0900 |
| commit | 789490eca8382edca34bae593e88cdc5fd4fe444 (patch) | |
| tree | 5bdffdd123248ed68d02a7bc75a98d8d82235b9f /lib/inets/test | |
| parent | 89939207898fc68a2ee0c080e603aa65fb866b25 (diff) | |
| download | otp-789490eca8382edca34bae593e88cdc5fd4fe444.tar.gz otp-789490eca8382edca34bae593e88cdc5fd4fe444.tar.bz2 otp-789490eca8382edca34bae593e88cdc5fd4fe444.zip | |
Fix {stream, {self, once}} in httpc
Previously the only difference between {stream, self} and {stream,
{self, once}} was an extra Pid in the stream_start message due to a
bug in httpc_handler. It was immediately sending a bunch of messages
till the end instead of waiting for httpc:stream_next/1 being called.
Diffstat (limited to 'lib/inets/test')
| -rw-r--r-- | lib/inets/test/httpc_SUITE.erl | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/lib/inets/test/httpc_SUITE.erl b/lib/inets/test/httpc_SUITE.erl index 350192464e..0c35f284f7 100644 --- a/lib/inets/test/httpc_SUITE.erl +++ b/lib/inets/test/httpc_SUITE.erl @@ -1693,6 +1693,15 @@ receive_streamed_body(RequestId, Body, Pid) -> ct:print("~p:receive_streamed_body -> requested next stream ~n", [?MODULE]), receive {http, {RequestId, stream, BinBodyPart}} -> + %% Make sure the httpc hasn't sent us the next 'stream' + %% without our request. + receive + {http, {RequestId, stream, _}} = Msg -> + ct:fail({unexpected_flood_of_stream, Msg}) + after + 1000 -> + ok + end, receive_streamed_body(RequestId, <<Body/binary, BinBodyPart/binary>>, Pid); |