diff options
| author | Mariano Guerra <[email protected]> | 2015-08-12 22:26:52 +0100 |
|---|---|---|
| committer | Mariano Guerra <[email protected]> | 2015-08-12 22:26:52 +0100 |
| commit | cba35d3d1d6c2532f3e4340cb0936ce54bc77a6e (patch) | |
| tree | e74e7d45448075d0e5662281c58701454d789e05 | |
| parent | a227184b3588f2b6e35cfe916d899ec945a1935b (diff) | |
| download | bullet-cba35d3d1d6c2532f3e4340cb0936ce54bc77a6e.tar.gz bullet-cba35d3d1d6c2532f3e4340cb0936ce54bc77a6e.tar.bz2 bullet-cba35d3d1d6c2532f3e4340cb0936ce54bc77a6e.zip | |
match against ok and close instead of crashing on close
| -rw-r--r-- | src/bullet_handler.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/bullet_handler.erl b/src/bullet_handler.erl index c576bda..f2fea5a 100644 --- a/src/bullet_handler.erl +++ b/src/bullet_handler.erl @@ -198,8 +198,10 @@ reply_get_mode(eventsource, Data, Req) -> Bin = iolist_to_binary(Data), Event = [[<<"data: ">>, Line, <<"\n">>] || Line <- binary:split(Bin, [<<"\r\n">>, <<"\r">>, <<"\n">>], [global])], - ok = cowboy_req:chunk([Event, <<"\n">>], Req), - {loop, Req}. + case cowboy_req:chunk([Event, <<"\n">>], Req) of + ok -> {loop, Req}; + close -> {ok, Req} + end. %% Internal. |