diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2022-03-30 11:29:22 +0200 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2022-05-09 10:52:36 +0200 |
| commit | da8c23d7ce98df0472b8b206cbd2715fb166bb8b (patch) | |
| tree | 24caf31ea28dec4982da2a487ff794f3fbe583bf | |
| parent | 7415abe3b5b90a4866f083e3b0c565887c05799b (diff) | |
| download | rabbitmq-server-git-da8c23d7ce98df0472b8b206cbd2715fb166bb8b.tar.gz | |
Adapt clause to send_chunk new return type
References #3753
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index 1319b542ef..b6c40a3daf 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -2563,9 +2563,8 @@ handle_frame_post_auth(Transport, [Reason]), %% likely a connection problem Consumer; - {{segment, Log1}, {credit, Credit1}} -> - Consumer#consumer{log = Log1, - credit = Credit1} + {ok, Csmr} -> + Csmr end, #consumer{configuration = #consumer_configuration{counters = |