@@ -1156,7 +1156,7 @@ async def test_read_message(
1156
1156
0 : PublicBatch (
1157
1157
messages = [stub_message (1 )],
1158
1158
_partition_session = stub_partition_session (),
1159
- _bytes_size = 0 ,
1159
+ _bytes_size = 4 ,
1160
1160
_codec = Codec .CODEC_RAW ,
1161
1161
)
1162
1162
},
@@ -1169,13 +1169,13 @@ async def test_read_message(
1169
1169
0 : PublicBatch (
1170
1170
messages = [stub_message (1 ), stub_message (2 )],
1171
1171
_partition_session = stub_partition_session (),
1172
- _bytes_size = 0 ,
1172
+ _bytes_size = 4 ,
1173
1173
_codec = Codec .CODEC_RAW ,
1174
1174
),
1175
1175
1 : PublicBatch (
1176
1176
messages = [stub_message (3 ), stub_message (4 )],
1177
1177
_partition_session = stub_partition_session (1 ),
1178
- _bytes_size = 0 ,
1178
+ _bytes_size = 4 ,
1179
1179
_codec = Codec .CODEC_RAW ,
1180
1180
),
1181
1181
},
@@ -1185,13 +1185,13 @@ async def test_read_message(
1185
1185
1 : PublicBatch (
1186
1186
messages = [stub_message (3 ), stub_message (4 )],
1187
1187
_partition_session = stub_partition_session (1 ),
1188
- _bytes_size = 0 ,
1188
+ _bytes_size = 4 ,
1189
1189
_codec = Codec .CODEC_RAW ,
1190
1190
),
1191
1191
0 : PublicBatch (
1192
1192
messages = [stub_message (2 )],
1193
1193
_partition_session = stub_partition_session (),
1194
- _bytes_size = 0 ,
1194
+ _bytes_size = 2 ,
1195
1195
_codec = Codec .CODEC_RAW ,
1196
1196
),
1197
1197
},
@@ -1201,13 +1201,13 @@ async def test_read_message(
1201
1201
0 : PublicBatch (
1202
1202
messages = [stub_message (1 )],
1203
1203
_partition_session = stub_partition_session (),
1204
- _bytes_size = 0 ,
1204
+ _bytes_size = 4 ,
1205
1205
_codec = Codec .CODEC_RAW ,
1206
1206
),
1207
1207
1 : PublicBatch (
1208
1208
messages = [stub_message (2 ), stub_message (3 )],
1209
1209
_partition_session = stub_partition_session (1 ),
1210
- _bytes_size = 0 ,
1210
+ _bytes_size = 4 ,
1211
1211
_codec = Codec .CODEC_RAW ,
1212
1212
),
1213
1213
},
@@ -1217,7 +1217,7 @@ async def test_read_message(
1217
1217
1 : PublicBatch (
1218
1218
messages = [stub_message (2 ), stub_message (3 )],
1219
1219
_partition_session = stub_partition_session (1 ),
1220
- _bytes_size = 0 ,
1220
+ _bytes_size = 4 ,
1221
1221
_codec = Codec .CODEC_RAW ,
1222
1222
)
1223
1223
},
0 commit comments