One more test for #15713

michaelklishin · michaelklishin · commit b69c01436a1f · 2026-03-11T17:43:10.000-07:00
diff --git a/deps/rabbitmq_stream/test/rabbit_stream_reader_SUITE.erl b/deps/rabbitmq_stream/test/rabbit_stream_reader_SUITE.erl
@@ -214,6 +214,20 @@ clean_subscriptions_should_remove_only_affected_subscriptions_test(_) ->
 
     ok.
 
+partial_frame_buffering_test(_) ->
+    Init = rabbit_stream_core:init(undefined),
+
+    State1 = rabbit_stream_core:incoming_data(<<0, 0, 0, 4>>, Init),
+    {Commands1, State2} = rabbit_stream_core:all_commands(State1),
+
+    ?assertEqual([], Commands1),
+
+    State3 = rabbit_stream_core:incoming_data(<<0, 0, 0, 4>>, State2),
+    {Commands2, _State4} = rabbit_stream_core:all_commands(State3),
+
+    ?assertEqual([], Commands2),
+    ok.
+
 consumer(S, Pid) ->
     #consumer{configuration = #consumer_configuration{stream = S,
                                                       member_pid = Pid}}.
