mirror of
https://github.com/toeverything/AFFiNE.git
synced 2026-02-18 14:56:59 +08:00
fix(core): unsub in LiveData.fromSignal (#10756)
This commit is contained in:
@@ -144,9 +144,13 @@ export class LiveData<T = unknown>
|
||||
static fromSignal<T>(signal: ReadonlySignal<T>): LiveData<T> {
|
||||
return LiveData.from(
|
||||
new Observable(subscriber => {
|
||||
signal.subscribe(value => {
|
||||
const unsubscribe = signal.subscribe(value => {
|
||||
subscriber.next(value);
|
||||
});
|
||||
|
||||
return () => {
|
||||
unsubscribe();
|
||||
};
|
||||
}),
|
||||
signal.value
|
||||
);
|
||||
|
||||
Reference in New Issue
Block a user