3.0.2

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "@push.rocks/smartbucket",
-  "version": "3.0.0",
+  "version": "3.0.2",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "@push.rocks/smartbucket",
-      "version": "3.0.0",
+      "version": "3.0.2",
       "license": "UNLICENSED",
       "dependencies": {
         "@push.rocks/smartpath": "^5.0.18",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/smartbucket",
-  "version": "3.0.0",
+  "version": "3.0.2",
   "description": "A TypeScript library for simple cloud independent object storage with support for buckets, directories, and files.",
   "main": "dist_ts/index.js",
   "typings": "dist_ts/index.d.ts",
@@ -12,7 +12,7 @@
     "build": "(tsbuild --web --allowimplicitany)"
   },
   "devDependencies": {
-    "@git.zone/tsbuild": "^2.1.76",
+    "@git.zone/tsbuild": "^2.1.80",
     "@git.zone/tsrun": "^1.2.46",
     "@git.zone/tstest": "^1.0.90",
     "@push.rocks/qenv": "^6.0.5",
@@ -22,7 +22,7 @@
     "@push.rocks/smartpath": "^5.0.18",
     "@push.rocks/smartpromise": "^4.0.3",
     "@push.rocks/smartrx": "^3.0.7",
-    "@push.rocks/smartstream": "^3.0.37",
+    "@push.rocks/smartstream": "^3.0.38",
     "@tsclass/tsclass": "^4.0.54",
     "minio": "^8.0.0"
   },

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/smartbucket',
-  version: '3.0.0',
+  version: '3.0.2',
   description: 'A TypeScript library for simple cloud independent object storage with support for buckets, directories, and files.'
 }

ts/smartbucket.classes.bucket.ts

@@ -96,14 +96,14 @@ export class Bucket {
       .getObject(this.name, optionsArg.path)
       .catch((e) => console.log(e));
     const replaySubject = new plugins.smartrx.rxjs.ReplaySubject<Buffer>();
-    const duplexStream = new plugins.smartstream.SmartDuplex<Buffer, Buffer>({
+    const duplexStream = new plugins.smartstream.SmartDuplex<Buffer, void>({
       writeFunction: async (chunk) => {
         replaySubject.next(chunk);
-        return chunk;
+        return;
       },
       finalFunction: async (cb) => {
         replaySubject.complete();
-        return Buffer.from('');
+        return;
       }
     });
 

ts/smartbucket.classes.directory.ts

@@ -71,6 +71,7 @@ export class Directory {
     );
     const fileArray: File[] = [];
     const duplexStream = new plugins.smartstream.SmartDuplex<plugins.minio.BucketItem, void>({
+      objectMode: true,
       writeFunction: async (bucketItem) => {
         if (bucketItem.prefix) {
           return;
@@ -113,6 +114,7 @@ export class Directory {
     );
     const directoryArray: Directory[] = [];
     const duplexStream = new plugins.smartstream.SmartDuplex<plugins.minio.BucketItem, void>({
+      objectMode: true,
       writeFunction: async (bucketItem) => {
         if (bucketItem.name) {
           return;