3.0.1

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "@push.rocks/smartbucket",
-  "version": "3.0.0",
+  "version": "3.0.1",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "@push.rocks/smartbucket",
-      "version": "3.0.0",
+      "version": "3.0.1",
       "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.1",
   "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",

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/smartbucket',
-  version: '3.0.0',
+  version: '3.0.1',
   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;