diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-12-09 11:33:28 +0100 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-12-09 11:33:28 +0100 |
| commit | 9a590647b3e4e941f6bf83efe9234c3d9cab21d2 (patch) | |
| tree | 9ad57a1c772d8d7ab775a616465471e492eb48cd | |
| parent | c0e3bc7e61fa0e07c5b5c5be40e3621661b60c4d (diff) | |
| download | rabbitmq-server-git-9a590647b3e4e941f6bf83efe9234c3d9cab21d2.tar.gz | |
Add chunk header parameter to send_file callback
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index 3aadd03f52..a63180aecf 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -1326,7 +1326,7 @@ subscription_exists(StreamSubscriptions, SubscriptionId) -> lists:any(fun(Id) -> Id =:= SubscriptionId end, SubscriptionIds). send_file_callback(Transport, #consumer{socket = S, subscription_id = SubscriptionId}, Counter) -> - fun(Size) -> + fun(_Header, Size) -> FrameSize = 2 + 2 + 1 + Size, FrameBeginning = <<FrameSize:32, ?COMMAND_DELIVER:16, ?VERSION_0:16, SubscriptionId:8/unsigned>>, Transport:send(S, FrameBeginning), |