1.0.38

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartbucket",
-  "version": "1.0.37",
+  "version": "1.0.38",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartbucket",
-  "version": "1.0.37",
+  "version": "1.0.38",
   "description": "simple cloud independent object storage",
   "main": "dist_ts/index.js",
   "typings": "dist_ts/index.d.ts",

ts/smartbucket.classes.bucket.ts

@@ -50,7 +50,7 @@ export class Bucket {
   /**
    * store file
    */
-  public async fastStore(pathArg: string, fileContent: string) {
+  public async fastStore(pathArg: string, fileContent: string | Buffer): Promise<void> {
     const streamIntake = new plugins.streamfunction.Intake();
     const putPromise = this.smartbucketRef.minioClient
       .putObject(this.name, pathArg, streamIntake.getReadable())
@@ -63,11 +63,11 @@ export class Bucket {
   /**
    * get file
    */
-  public async fastGet(pathArg: string) {
+  public async fastGet(pathArg: string): Promise<Buffer> {
     const done = plugins.smartpromise.defer();
     let completeFile: Buffer;
     const replaySubject = await this.fastGetStream(pathArg);
-    replaySubject.subscribe(
+    const subscription = replaySubject.subscribe(
       (chunk) => {
         if (completeFile) {
           completeFile = Buffer.concat([completeFile, chunk]);
@@ -78,6 +78,7 @@ export class Bucket {
       },
       () => {
         done.resolve();
+        subscription.unsubscribe();
       }
     );
     await done.promise;