Add tests

lib/src/minio_client.dart

@@ -20,29 +20,35 @@ class MinioRequest extends BaseRequest {
   ByteStream finalize() {
     super.finalize();
 
-    late final ByteStream byteStream;
+    if (body == null) {
+      return const ByteStream(Stream.empty());
+    }
+
+    if (body is Stream<Uint8List>) {
+      return ByteStream(body);
+    }
+
+    late Stream<Uint8List> stream;
 
     if (body is String) {
-      final data = utf8.encode(body);
+      final data = Utf8Encoder().convert(body);
       headers['content-length'] = data.length.toString();
-      byteStream = ByteStream.fromBytes(utf8.encode(body));
-    } else if (body is List<int>) {
+      stream = Stream<Uint8List>.value(data);
+    } else if (body is Uint8List) {
+      stream = Stream<Uint8List>.value(body);
       headers['content-length'] = body.length.toString();
-      byteStream = ByteStream.fromBytes(body);
-    } else if (body is Stream<List<int>>) {
-      byteStream = ByteStream(body);
-    } else {
-      throw UnsupportedError('unsupported body type: ${body.runtimeType}');
     }
 
+    stream = stream.transform(BlockStream(1 << 16));
+
     if (onProgress == null) {
-      return byteStream;
+      return ByteStream(stream);
     }
 
     var bytesRead = 0;
 
     return ByteStream(
-      byteStream.transform(
+      stream.transform(
         StreamTransformer.fromHandlers(
           handleData: (data, sink) {
             sink.add(data);

lib/src/minio_uploader.dart

@@ -118,7 +118,7 @@ class MinioUploader implements StreamConsumer<Uint8List> {
       queries: queries,
       bucket: bucket,
       object: object,
-      payload: Stream.value(chunk).transform(BlockStream(1 << 16)),
+      payload: chunk,
       onProgress: _updateProgress,
     );
 

test/minio_test.dart

@@ -398,8 +398,33 @@ void testPutObject() {
         Stream.value(objectData),
         onProgress: (bytes) => progress = bytes,
       );
+      await minio.removeObject(bucketName, objectName);
       expect(progress, equals(objectData.length));
+    });
+
+    test('medium size file upload works', () async {
+      final objectName = uniqueName();
+      final dataLength = 1024 * 1024;
+      final data = Uint8List.fromList(List<int>.generate(dataLength, (i) => i));
+      await minio.putObject(bucketName, objectName, Stream.value(data));
+      final stat = await minio.statObject(bucketName, objectName);
+      await minio.removeObject(bucketName, objectName);
+      expect(stat.size, equals(dataLength));
+    });
+
+    test('large file upload works', () async {
+      final objectName = uniqueName();
+      final dataLength = 12 * 1024 * 1024;
+      final data = Uint8List.fromList(List<int>.generate(dataLength, (i) => i));
+      await minio.putObject(
+        bucketName,
+        objectName,
+        Stream.value(data),
+        chunkSize: 5 * 1024 * 1024,
+      );
+      final stat = await minio.statObject(bucketName, objectName);
       await minio.removeObject(bucketName, objectName);
+      expect(stat.size, equals(dataLength));
     });
   });
 }