From f0e0dcc6edfa8710c92d1f114aa52ab6a2271b86 Mon Sep 17 00:00:00 2001
From: Martin Karkowski <m.karkowski@dozema.local>
Date: Tue, 8 Sep 2020 16:58:50 +0200
Subject: [PATCH] Fixing Observables

---
 lib/observables/nopeObservable.ts       | 4 ++++
 lib/observables/nopeRemoteObservable.ts | 2 +-
 test/testNopeObservable.ts              | 4 ++--
 3 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/lib/observables/nopeObservable.ts b/lib/observables/nopeObservable.ts
index e5a1f9c..fe63a24 100644
--- a/lib/observables/nopeObservable.ts
+++ b/lib/observables/nopeObservable.ts
@@ -376,4 +376,8 @@ export class nopeObservable<T, S = T, G = T> {
       }
     })
   }
+
+  public get hasSubscriptions() {
+    return this.observable.observers.length > 0;
+  }
 }
\ No newline at end of file
diff --git a/lib/observables/nopeRemoteObservable.ts b/lib/observables/nopeRemoteObservable.ts
index aa07a57..288009d 100644
--- a/lib/observables/nopeRemoteObservable.ts
+++ b/lib/observables/nopeRemoteObservable.ts
@@ -3,7 +3,7 @@ import { nopeDispatcher } from "../dispatcher/nopeDispatcher";
 
 export type pipe<T, K> = (scope: { [index: string]: any }, observable: Observable<T>) => Observable<K>
 
-export class nopeRemoteObservable<G, S = G> {
+export class nopeRemoteObservable<T, S = T, G = T> {
   protected _pathes: {
     get: string,
     set: string,
diff --git a/test/testNopeObservable.ts b/test/testNopeObservable.ts
index e613162..788f9a8 100644
--- a/test/testNopeObservable.ts
+++ b/test/testNopeObservable.ts
@@ -23,6 +23,6 @@ const subEnhanced = observable.enhancedSubscription((v) => console.log('enhanced
 
 let i = 1;
 while (i < 20) {
-  observable.value = i++;
-  console.log('current', observable.value);
+  observable.setContent(i++);
+  console.log('current', observable.getContent());
 }
\ No newline at end of file