Skip to content

Commit 9a59064

Browse files
committed
Add chunk header parameter to send_file callback
1 parent c0e3bc7 commit 9a59064

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbitmq_stream/src/rabbit_stream_reader.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1326,7 +1326,7 @@ subscription_exists(StreamSubscriptions, SubscriptionId) ->
13261326
lists:any(fun(Id) -> Id =:= SubscriptionId end, SubscriptionIds).
13271327

13281328
send_file_callback(Transport, #consumer{socket = S, subscription_id = SubscriptionId}, Counter) ->
1329-
fun(Size) ->
1329+
fun(_Header, Size) ->
13301330
FrameSize = 2 + 2 + 1 + Size,
13311331
FrameBeginning = <<FrameSize:32, ?COMMAND_DELIVER:16, ?VERSION_0:16, SubscriptionId:8/unsigned>>,
13321332
Transport:send(S, FrameBeginning),

0 commit comments

Comments
 (0)