Patch Adapter methods resolver

package-dist.json

@@ -1,6 +1,6 @@
 {
   "name": "ngx-ui-scroll",
-  "version": "1.8.2",
+  "version": "1.8.3",
   "description": "Infinite/virtual scroll for Angular",
   "main": "./bundles/ngx-ui-scroll.umd.js",
   "module": "./fesm5/ngx-ui-scroll.js",

package.json

@@ -14,7 +14,7 @@
     "deploy-app": "npm run build-app && firebase deploy",
     "preinstall": "cd server && npm install",
     "postinstall": "npm run build-app",
-    "pack:install": "npm run build && npm pack ./dist && npm install ngx-ui-scroll-1.8.2.tgz --no-save",
+    "pack:install": "npm run build && npm pack ./dist && npm install ngx-ui-scroll-1.8.3.tgz --no-save",
     "pack:start": "npm run pack:install && npm start",
     "build": "node build.js",
     "publish:lib": "npm run build && npm publish ./dist",

src/component/classes/adapter.ts

@@ -73,23 +73,28 @@ export class Adapter implements IAdapter {
   eof$: Subject<boolean>;
   itemsCount: number;
 
-  private relax$: Subject<AdapterMethodRelax>;
+  private relax$: Subject<AdapterMethodRelax> | null;
 
   private getPromisifiedMethod(method: Function) {
     return (...args: any[]) =>
       new Promise(resolve => {
-        this.relax$.pipe(
-          filter(value => !!value),
-          take(1)
-        ).subscribe(value => resolve(value));
+        if (this.relax$) {
+          this.relax$.pipe(
+            filter(value => !!value),
+            take(1)
+          ).subscribe(value => resolve(value));
+        }
         method.apply(this, args);
+        if (!this.relax$) {
+          resolve();
+        }
       });
   }
 
   constructor(publicContext: IAdapter | null, getWorkflow: WorkflowGetter, logger: Logger) {
     this.getWorkflow = getWorkflow;
     this.logger = logger;
-    this.relax$ = new Subject<AdapterMethodRelax>();
+    this.relax$ = null;
 
     // restore original values from the publicContext if present
     const adapterProps = publicContext
@@ -201,19 +206,23 @@ export class Adapter implements IAdapter {
 
     // self-pending
     if (onAdapterRun$) {
+      if (!this.relax$) {
+        this.relax$ = new Subject<AdapterMethodRelax>();
+      }
+      const relax$ = this.relax$;
       onAdapterRun$.subscribe(({ status, payload }) => {
         let isLoadingSub;
         if (status === ProcessStatus.start) {
-          this.relax$.next(false);
+          relax$.next(false);
           isLoadingSub = this.isLoading$
             .pipe(filter(isLoading => !isLoading), take(1))
-            .subscribe(() => this.relax$.next({ success: true, immediate: false }));
+            .subscribe(() => relax$.next({ success: true, immediate: false }));
         }
         if (status === ProcessStatus.done || status === ProcessStatus.error) {
           if (isLoadingSub) {
             isLoadingSub.unsubscribe();
           }
-          this.relax$.next({
+          relax$.next({
             success: status !== ProcessStatus.error,
             immediate: true,
             ...(status === ProcessStatus.error ? { error: payload ? payload.error : 'true' } : {})
@@ -224,7 +233,9 @@ export class Adapter implements IAdapter {
   }
 
   dispose() {
-    this.relax$.complete();
+    if (this.relax$) {
+      this.relax$.complete();
+    }
    }
 
   reset(options?: IDatasourceOptional): any {

src/component/processes/clip.ts

@@ -47,6 +47,7 @@ export default class Clip {
       `, range: [${clipped[0]}..${clipped[clipped.length - 1]}]`
     ]);
     logger.stat('after clip');
+    clip.reset();
   }
 
 }

src/ui-scroll.version.ts

@@ -1 +1 @@
-export default '1.8.2';
+export default '1.8.3';

tests/adapter.clip.spec.ts

@@ -145,5 +145,14 @@ describe('Adapter Clip Spec', () => {
     })
   );
 
+  makeTest({
+    config: { datasourceSettings: { adapter: true } },
+    title: `should resolve immediately before scroller initialization`,
+    it: (misc: Misc) => async (done: Function) => {
+      await misc.adapter.clip();
+      done();
+    }
+  });
+
 });