1.0.30

package-lock.json

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

package.json

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

ts/smartbucket.classes.bucket.ts

@@ -65,11 +65,13 @@ export class Bucket {
    */
   public async fastGet(pathArg: string) {
     const done = plugins.smartpromise.defer();
-    let completeFile: string = '';
+    let completeFile: Buffer;
     const replaySubject = await this.fastGetStream(pathArg);
     replaySubject.subscribe(
-      chunkString => {
+      chunk => {
-        completeFile += chunkString;
+        if (completeFile) {
+          completeFile = Buffer.concat([completeFile, chunk]);
+        }
       },
       err => {
         console.log(err);
@@ -82,15 +84,14 @@ export class Bucket {
     return completeFile;
   }
 
-  public async fastGetStream(pathArg: string): Promise<plugins.smartrx.rxjs.ReplaySubject<string>> {
+  public async fastGetStream(pathArg: string): Promise<plugins.smartrx.rxjs.ReplaySubject<Buffer>> {
     const fileStream = await this.smartbucketRef.minioClient
       .getObject(this.name, pathArg)
       .catch(e => console.log(e));
-    const replaySubject = new plugins.smartrx.rxjs.ReplaySubject<string>();
+    const replaySubject = new plugins.smartrx.rxjs.ReplaySubject<Buffer>();
     const duplexStream = plugins.streamfunction.createDuplexStream<Buffer, Buffer>(
       async chunk => {
-        const chunkString = chunk.toString();
+        replaySubject.next(chunk);
-        replaySubject.next(chunkString);
         return chunk;
       },
       async cb => {

ts/smartbucket.classes.directory.ts

@@ -184,7 +184,7 @@ export class Directory {
     return result;
   }
 
-  public async fastGetStream(pathArg: string): Promise<plugins.smartrx.rxjs.ReplaySubject<string>> {
+  public async fastGetStream(pathArg: string): Promise<plugins.smartrx.rxjs.ReplaySubject<Buffer>> {
     const path = plugins.path.join(this.getBasePath(), pathArg);
     const result = await this.bucketRef.fastGetStream(path);
     return result;