@maybe-remote/rxjs
Advanced tools
Comparing version 0.0.5 to 0.0.6
@@ -0,1 +1,8 @@ | ||
## 0.0.6 (2024-10-15) | ||
### 🩹 Fixes | ||
- **rxjs:** subscriptions no longer weirdly multicast ([c2166b2](https://github.com/benlesh/maybe-remote/commit/c2166b2)) | ||
## 0.0.5 (2024-10-14) | ||
@@ -2,0 +9,0 @@ |
{ | ||
"name": "@maybe-remote/rxjs", | ||
"version": "0.0.5", | ||
"version": "0.0.6", | ||
"dependencies": { | ||
@@ -5,0 +5,0 @@ "tslib": "^2.3.0" |
@@ -251,3 +251,3 @@ import { | ||
return (...params: any[]) => { | ||
const subscriptionId = crypto.randomUUID(); | ||
const observableId = crypto.randomUUID(); | ||
@@ -257,3 +257,3 @@ connection.send({ | ||
payload: { | ||
subscriptionId, | ||
observableId, | ||
method, | ||
@@ -265,2 +265,4 @@ params, | ||
const observable = new Observable<any>((subscriber) => { | ||
const subscriptionId = crypto.randomUUID(); | ||
const dispose = connection.onMessage((message) => { | ||
@@ -302,2 +304,3 @@ switch (message.type) { | ||
payload: { | ||
observableId, | ||
subscriptionId, | ||
@@ -308,3 +311,3 @@ }, | ||
this.refs.set(subscriptionId, new WeakRef(observable)); | ||
this.refs.set(observableId, new WeakRef(observable)); | ||
@@ -311,0 +314,0 @@ return observable; |
12718
392