dees-element/ts/dees-element.classes.subscribedirective.ts

38 lines
869 B
TypeScript
Raw Permalink Normal View History

2023-03-15 21:22:30 +00:00
import { noChange } from 'lit';
import { AsyncDirective, directive } from 'lit/async-directive.js';
2023-08-07 07:19:53 +00:00
import { rxjs } from '@push.rocks/smartrx';
2023-03-15 21:22:30 +00:00
class SubscribeDirective extends AsyncDirective {
observable: rxjs.Observable<unknown> | undefined;
sub: rxjs.Subscription | null = null;
render(observable: rxjs.Observable<unknown>) {
if (this.observable !== observable) {
this.sub?.unsubscribe();
this.observable = observable;
if (this.isConnected) {
this.subscribe(observable);
}
}
return noChange;
}
subscribe(observable: rxjs.Observable<unknown>) {
this.sub = observable.subscribe((v: unknown) => {
this.setValue(v);
});
}
disconnected() {
this.sub?.unsubscribe();
}
reconnected() {
this.subscribe(this.observable!);
}
}
2023-08-07 07:19:53 +00:00
export const subscribe = directive(SubscribeDirective);