From 5d8f5693399600e2a7cd6e9766742eb53dc3d723 Mon Sep 17 00:00:00 2001
From: Philipp Kunz <gitlab@philkunz.com>
Date: Mon, 24 Jan 2022 07:37:52 +0100
Subject: [PATCH] fix(core): update

---
 ts/smartrx.classes.observableintake.ts | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/ts/smartrx.classes.observableintake.ts b/ts/smartrx.classes.observableintake.ts
index fac979d..59d2f82 100644
--- a/ts/smartrx.classes.observableintake.ts
+++ b/ts/smartrx.classes.observableintake.ts
@@ -1,10 +1,12 @@
 import * as plugins from './smartrx.plugins';
 
+import * as rxjs from './smartrx.plugins.rxjs';
+
 /**
  * ObservableIntake
  */
 export class ObservableIntake<T> {
-  public observable: plugins.rxjs.Observable<T>;
+  public observable: rxjs.Observable<T>;
   public completed: Promise<void>;
   private completedDeffered: plugins.smartpromise.Deferred<void>;
   private observableFunctions: any = {
@@ -20,7 +22,7 @@ export class ObservableIntake<T> {
   private payloadBuffer: any[] = [];
 
   constructor() {
-    this.observable = plugins.rxjs.Observable.create((observerArg: plugins.rxjs.Observer<any>) => {
+    this.observable = rxjs.Observable.create((observerArg: rxjs.Observer<any>) => {
       this.observableFunctions.next = (...args: any) => {
         return observerArg.next(args);
       };
@@ -33,7 +35,7 @@ export class ObservableIntake<T> {
     this.completed = this.completedDeffered.promise;
   }
 
-  public setObservable(observableFunc: plugins.rxjs.Observable<any>) {
+  public setObservable(observableFunc: rxjs.Observable<any>) {
     this.observable = observableFunc;
   }