mirrors/vector-im-hydrogen-web
1
0
Fork 0
mirror of https://github.com/vector-im/hydrogen-web.git synced 2024-12-23 11:35:04 +01:00
Code Issues Projects Releases Wiki Activity

typescriptifies SourceSubscriptionHandler

Browse Source
This commit is contained in:
Isaiah Becker-Mayer 2022-07-08 20:39:07 -04:00
parent 63e9b49ebe
commit edeec896ae
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/observable/map/JoinedMap.ts
View File

@ -19,12 +19,13 @@ import {config} from "./config";
import {FilteredMap} from "./FilteredMap.js"; import {FilteredMap} from "./FilteredMap.js";
import {MappedMap} from "./MappedMap.js"; import {MappedMap} from "./MappedMap.js";
import {SortedMapList} from "../list/SortedMapList.js"; import {SortedMapList} from "../list/SortedMapList.js";
import {SubscriptionHandle} from "../BaseObservable"
export class JoinedMap<K, V> extends BaseObservableMap<K, V> { export class JoinedMap<K, V> extends BaseObservableMap<K, V> {
protected _sources: BaseObservableMap<K, V>[]; protected _sources: BaseObservableMap<K, V>[];
private _config: BaseObservableMapConfig<K, V> private _config: BaseObservableMapConfig<K, V>
private _subscriptions?: SourceSubscriptionHandler[]; private _subscriptions?: SourceSubscriptionHandler<K, V>[];
constructor(sources: BaseObservableMap<K, V>[]) { constructor(sources: BaseObservableMap<K, V>[]) {
super(); super();
@ -186,11 +187,15 @@ class JoinedIterator<K, V> implements Iterator<[K, V]> {
} }
} }
class SourceSubscriptionHandler { class SourceSubscriptionHandler<K, V> {
constructor(source, joinedMap) { private _source: BaseObservableMap<K, V>;
private _joinedMap: JoinedMap<K, V>;
private _subscription?: SubscriptionHandle;
constructor(source: BaseObservableMap<K, V>, joinedMap: JoinedMap<K, V>) {
this._source = source; this._source = source;
this._joinedMap = joinedMap; this._joinedMap = joinedMap;
this._subscription = null; this._subscription = undefined;
} }
subscribe() { subscribe() {
@ -199,23 +204,23 @@ class SourceSubscriptionHandler {
} }
dispose() { dispose() {
this._subscription = this._subscription(); if (this._subscription) this._subscription = this._subscription();
} }
onAdd(key, value) { onAdd(key: K, value: V) {
this._joinedMap.onAdd(this._source, key, value); this._joinedMap.onAdd(this._source, key, value);
} }
onRemove(key, value) { onRemove(key: K, value: V) {
this._joinedMap.onRemove(this._source, key, value); this._joinedMap.onRemove(this._source, key, value);
} }
onUpdate(key, value, params) { onUpdate(key: K, value: V, params: any) {
this._joinedMap.onUpdate(this._source, key, value, params); this._joinedMap.onUpdate(this._source, key, value, params);
} }
onReset() { onReset() {
this._joinedMap.onReset(this._source); this._joinedMap.onReset();
} }
} }