diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-09-16 10:31:12 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-09-16 10:31:12 +0100 |
| commit | 464c9b22caacf24dd7cac51aba887a7a1485abc3 (patch) | |
| tree | ec074ad74155061107fa11f36dcefba4e12c903a /src | |
| parent | 6b143c5f5a5e341ebc6987a5a088c36e12c3f85a (diff) | |
| download | rabbitmq-server-git-464c9b22caacf24dd7cac51aba887a7a1485abc3.tar.gz | |
merge two folds
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 119a3d03ab..36aee755a8 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1207,13 +1207,13 @@ handle_consuming_queue_down(QPid, error -> gb_sets:new(); {ok, CTags} -> CTags end, - ConsumerMapping1 = gb_sets:fold(fun dict:erase/2, - ConsumerMapping, ConsumerTags), - [begin - Cancel = #'basic.cancel'{consumer_tag = ConsumerTag, - nowait = true}, - ok = rabbit_writer:send_command(WriterPid, Cancel) - end || ConsumerTag <- gb_sets:to_list(ConsumerTags)], + ConsumerMapping1 = + gb_sets:fold(fun (CTag, CMap) -> + Cancel = #'basic.cancel'{consumer_tag = CTag, + nowait = true}, + ok = rabbit_writer:send_command(WriterPid, Cancel), + dict:erase(CTag, CMap) + end, ConsumerMapping, ConsumerTags), State#ch{consumer_mapping = ConsumerMapping1, queue_consumers = dict:erase(QPid, QCons)}. |