@@ -1156,7 +1156,7 @@ async def test_read_message(
11561156 0 : PublicBatch (
11571157 messages = [stub_message (1 )],
11581158 _partition_session = stub_partition_session (),
1159- _bytes_size = 0 ,
1159+ _bytes_size = 4 ,
11601160 _codec = Codec .CODEC_RAW ,
11611161 )
11621162 },
@@ -1169,13 +1169,13 @@ async def test_read_message(
11691169 0 : PublicBatch (
11701170 messages = [stub_message (1 ), stub_message (2 )],
11711171 _partition_session = stub_partition_session (),
1172- _bytes_size = 0 ,
1172+ _bytes_size = 4 ,
11731173 _codec = Codec .CODEC_RAW ,
11741174 ),
11751175 1 : PublicBatch (
11761176 messages = [stub_message (3 ), stub_message (4 )],
11771177 _partition_session = stub_partition_session (1 ),
1178- _bytes_size = 0 ,
1178+ _bytes_size = 4 ,
11791179 _codec = Codec .CODEC_RAW ,
11801180 ),
11811181 },
@@ -1185,13 +1185,13 @@ async def test_read_message(
11851185 1 : PublicBatch (
11861186 messages = [stub_message (3 ), stub_message (4 )],
11871187 _partition_session = stub_partition_session (1 ),
1188- _bytes_size = 0 ,
1188+ _bytes_size = 4 ,
11891189 _codec = Codec .CODEC_RAW ,
11901190 ),
11911191 0 : PublicBatch (
11921192 messages = [stub_message (2 )],
11931193 _partition_session = stub_partition_session (),
1194- _bytes_size = 0 ,
1194+ _bytes_size = 2 ,
11951195 _codec = Codec .CODEC_RAW ,
11961196 ),
11971197 },
@@ -1201,13 +1201,13 @@ async def test_read_message(
12011201 0 : PublicBatch (
12021202 messages = [stub_message (1 )],
12031203 _partition_session = stub_partition_session (),
1204- _bytes_size = 0 ,
1204+ _bytes_size = 4 ,
12051205 _codec = Codec .CODEC_RAW ,
12061206 ),
12071207 1 : PublicBatch (
12081208 messages = [stub_message (2 ), stub_message (3 )],
12091209 _partition_session = stub_partition_session (1 ),
1210- _bytes_size = 0 ,
1210+ _bytes_size = 4 ,
12111211 _codec = Codec .CODEC_RAW ,
12121212 ),
12131213 },
@@ -1217,7 +1217,7 @@ async def test_read_message(
12171217 1 : PublicBatch (
12181218 messages = [stub_message (2 ), stub_message (3 )],
12191219 _partition_session = stub_partition_session (1 ),
1220- _bytes_size = 0 ,
1220+ _bytes_size = 4 ,
12211221 _codec = Codec .CODEC_RAW ,
12221222 )
12231223 },
0 commit comments