You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
263 lines
13 KiB
263 lines
13 KiB
(function (global, factory) {
|
|
typeof exports === 'object' && typeof module !== 'undefined' ? factory(require('@angular/core'),exports, require('@angular/cdk/coercion'), require('@angular/core'), require('rxjs'), require('rxjs/operators')) :
|
|
typeof define === 'function' && define.amd ? define('@angular/cdk/observers', ['@angular/core','exports', '@angular/cdk/coercion', '@angular/core', 'rxjs', 'rxjs/operators'], factory) :
|
|
(global = typeof globalThis !== 'undefined' ? globalThis : global || self, factory(global.ng.core,(global.ng = global.ng || {}, global.ng.cdk = global.ng.cdk || {}, global.ng.cdk.observers = {}), global.ng.cdk.coercion, global.ng.core, global.rxjs, global.rxjs.operators));
|
|
}(this, (function (ɵngcc0,exports, coercion, i0, rxjs, operators) { 'use strict';
|
|
|
|
function _interopNamespace(e) {
|
|
if (e && e.__esModule) return e;
|
|
var n = Object.create(null);
|
|
if (e) {
|
|
Object.keys(e).forEach(function (k) {
|
|
if (k !== 'default') {
|
|
var d = Object.getOwnPropertyDescriptor(e, k);
|
|
Object.defineProperty(n, k, d.get ? d : {
|
|
enumerable: true,
|
|
get: function () {
|
|
return e[k];
|
|
}
|
|
});
|
|
}
|
|
});
|
|
}
|
|
n['default'] = e;
|
|
return Object.freeze(n);
|
|
}
|
|
|
|
var i0__namespace = /*#__PURE__*/_interopNamespace(i0);
|
|
|
|
/**
|
|
* @license
|
|
* Copyright Google LLC All Rights Reserved.
|
|
*
|
|
* Use of this source code is governed by an MIT-style license that can be
|
|
* found in the LICENSE file at https://angular.io/license
|
|
*/
|
|
/**
|
|
* Factory that creates a new MutationObserver and allows us to stub it out in unit tests.
|
|
* @docs-private
|
|
*/
|
|
var MutationObserverFactory = /** @class */ (function () {
|
|
function MutationObserverFactory() {
|
|
}
|
|
MutationObserverFactory.prototype.create = function (callback) {
|
|
return typeof MutationObserver === 'undefined' ? null : new MutationObserver(callback);
|
|
};
|
|
MutationObserverFactory.ɵfac = function MutationObserverFactory_Factory(t) { return new (t || MutationObserverFactory)(); };
|
|
(function () { (typeof ngDevMode === "undefined" || ngDevMode) && ɵngcc0.ɵsetClassMetadata(MutationObserverFactory, [{
|
|
type: i0.Injectable,
|
|
args: [{ providedIn: 'root' }]
|
|
}], function () { return []; }, null); })();
|
|
return MutationObserverFactory;
|
|
}());
|
|
MutationObserverFactory.ɵprov = i0__namespace.ɵɵdefineInjectable({ factory: function MutationObserverFactory_Factory() { return new MutationObserverFactory(); }, token: MutationObserverFactory, providedIn: "root" });
|
|
/** An injectable service that allows watching elements for changes to their content. */
|
|
var ContentObserver = /** @class */ (function () {
|
|
function ContentObserver(_mutationObserverFactory) {
|
|
this._mutationObserverFactory = _mutationObserverFactory;
|
|
/** Keeps track of the existing MutationObservers so they can be reused. */
|
|
this._observedElements = new Map();
|
|
}
|
|
ContentObserver.prototype.ngOnDestroy = function () {
|
|
var _this = this;
|
|
this._observedElements.forEach(function (_, element) { return _this._cleanupObserver(element); });
|
|
};
|
|
ContentObserver.prototype.observe = function (elementOrRef) {
|
|
var _this = this;
|
|
var element = coercion.coerceElement(elementOrRef);
|
|
return new rxjs.Observable(function (observer) {
|
|
var stream = _this._observeElement(element);
|
|
var subscription = stream.subscribe(observer);
|
|
return function () {
|
|
subscription.unsubscribe();
|
|
_this._unobserveElement(element);
|
|
};
|
|
});
|
|
};
|
|
/**
|
|
* Observes the given element by using the existing MutationObserver if available, or creating a
|
|
* new one if not.
|
|
*/
|
|
ContentObserver.prototype._observeElement = function (element) {
|
|
if (!this._observedElements.has(element)) {
|
|
var stream_1 = new rxjs.Subject();
|
|
var observer = this._mutationObserverFactory.create(function (mutations) { return stream_1.next(mutations); });
|
|
if (observer) {
|
|
observer.observe(element, {
|
|
characterData: true,
|
|
childList: true,
|
|
subtree: true
|
|
});
|
|
}
|
|
this._observedElements.set(element, { observer: observer, stream: stream_1, count: 1 });
|
|
}
|
|
else {
|
|
this._observedElements.get(element).count++;
|
|
}
|
|
return this._observedElements.get(element).stream;
|
|
};
|
|
/**
|
|
* Un-observes the given element and cleans up the underlying MutationObserver if nobody else is
|
|
* observing this element.
|
|
*/
|
|
ContentObserver.prototype._unobserveElement = function (element) {
|
|
if (this._observedElements.has(element)) {
|
|
this._observedElements.get(element).count--;
|
|
if (!this._observedElements.get(element).count) {
|
|
this._cleanupObserver(element);
|
|
}
|
|
}
|
|
};
|
|
/** Clean up the underlying MutationObserver for the specified element. */
|
|
ContentObserver.prototype._cleanupObserver = function (element) {
|
|
if (this._observedElements.has(element)) {
|
|
var _b = this._observedElements.get(element), observer = _b.observer, stream = _b.stream;
|
|
if (observer) {
|
|
observer.disconnect();
|
|
}
|
|
stream.complete();
|
|
this._observedElements.delete(element);
|
|
}
|
|
};
|
|
ContentObserver.ɵfac = function ContentObserver_Factory(t) { return new (t || ContentObserver)(ɵngcc0.ɵɵinject(MutationObserverFactory)); };
|
|
(function () { (typeof ngDevMode === "undefined" || ngDevMode) && ɵngcc0.ɵsetClassMetadata(ContentObserver, [{
|
|
type: i0.Injectable,
|
|
args: [{ providedIn: 'root' }]
|
|
}], function () { return [{ type: MutationObserverFactory }]; }, null); })();
|
|
return ContentObserver;
|
|
}());
|
|
ContentObserver.ɵprov = i0__namespace.ɵɵdefineInjectable({ factory: function ContentObserver_Factory() { return new ContentObserver(i0__namespace.ɵɵinject(MutationObserverFactory)); }, token: ContentObserver, providedIn: "root" });
|
|
ContentObserver.ctorParameters = function () { return [
|
|
{ type: MutationObserverFactory }
|
|
]; };
|
|
/**
|
|
* Directive that triggers a callback whenever the content of
|
|
* its associated element has changed.
|
|
*/
|
|
var CdkObserveContent = /** @class */ (function () {
|
|
function CdkObserveContent(_contentObserver, _elementRef, _ngZone) {
|
|
this._contentObserver = _contentObserver;
|
|
this._elementRef = _elementRef;
|
|
this._ngZone = _ngZone;
|
|
/** Event emitted for each change in the element's content. */
|
|
this.event = new i0.EventEmitter();
|
|
this._disabled = false;
|
|
this._currentSubscription = null;
|
|
}
|
|
Object.defineProperty(CdkObserveContent.prototype, "disabled", {
|
|
/**
|
|
* Whether observing content is disabled. This option can be used
|
|
* to disconnect the underlying MutationObserver until it is needed.
|
|
*/
|
|
get: function () { return this._disabled; },
|
|
set: function (value) {
|
|
this._disabled = coercion.coerceBooleanProperty(value);
|
|
this._disabled ? this._unsubscribe() : this._subscribe();
|
|
},
|
|
enumerable: false,
|
|
configurable: true
|
|
});
|
|
Object.defineProperty(CdkObserveContent.prototype, "debounce", {
|
|
/** Debounce interval for emitting the changes. */
|
|
get: function () { return this._debounce; },
|
|
set: function (value) {
|
|
this._debounce = coercion.coerceNumberProperty(value);
|
|
this._subscribe();
|
|
},
|
|
enumerable: false,
|
|
configurable: true
|
|
});
|
|
CdkObserveContent.prototype.ngAfterContentInit = function () {
|
|
if (!this._currentSubscription && !this.disabled) {
|
|
this._subscribe();
|
|
}
|
|
};
|
|
CdkObserveContent.prototype.ngOnDestroy = function () {
|
|
this._unsubscribe();
|
|
};
|
|
CdkObserveContent.prototype._subscribe = function () {
|
|
var _this = this;
|
|
this._unsubscribe();
|
|
var stream = this._contentObserver.observe(this._elementRef);
|
|
// TODO(mmalerba): We shouldn't be emitting on this @Output() outside the zone.
|
|
// Consider brining it back inside the zone next time we're making breaking changes.
|
|
// Bringing it back inside can cause things like infinite change detection loops and changed
|
|
// after checked errors if people's code isn't handling it properly.
|
|
this._ngZone.runOutsideAngular(function () {
|
|
_this._currentSubscription =
|
|
(_this.debounce ? stream.pipe(operators.debounceTime(_this.debounce)) : stream).subscribe(_this.event);
|
|
});
|
|
};
|
|
CdkObserveContent.prototype._unsubscribe = function () {
|
|
var _a;
|
|
(_a = this._currentSubscription) === null || _a === void 0 ? void 0 : _a.unsubscribe();
|
|
};
|
|
CdkObserveContent.ɵfac = function CdkObserveContent_Factory(t) { return new (t || CdkObserveContent)(ɵngcc0.ɵɵdirectiveInject(ContentObserver), ɵngcc0.ɵɵdirectiveInject(ɵngcc0.ElementRef), ɵngcc0.ɵɵdirectiveInject(ɵngcc0.NgZone)); };
|
|
CdkObserveContent.ɵdir = /*@__PURE__*/ ɵngcc0.ɵɵdefineDirective({ type: CdkObserveContent, selectors: [["", "cdkObserveContent", ""]], inputs: { disabled: ["cdkObserveContentDisabled", "disabled"], debounce: "debounce" }, outputs: { event: "cdkObserveContent" }, exportAs: ["cdkObserveContent"] });
|
|
(function () { (typeof ngDevMode === "undefined" || ngDevMode) && ɵngcc0.ɵsetClassMetadata(CdkObserveContent, [{
|
|
type: i0.Directive,
|
|
args: [{
|
|
selector: '[cdkObserveContent]',
|
|
exportAs: 'cdkObserveContent'
|
|
}]
|
|
}], function () { return [{ type: ContentObserver }, { type: ɵngcc0.ElementRef }, { type: ɵngcc0.NgZone }]; }, { event: [{
|
|
type: i0.Output,
|
|
args: ['cdkObserveContent']
|
|
}], disabled: [{
|
|
type: i0.Input,
|
|
args: ['cdkObserveContentDisabled']
|
|
}], debounce: [{
|
|
type: i0.Input
|
|
}] }); })();
|
|
return CdkObserveContent;
|
|
}());
|
|
CdkObserveContent.ctorParameters = function () { return [
|
|
{ type: ContentObserver },
|
|
{ type: i0.ElementRef },
|
|
{ type: i0.NgZone }
|
|
]; };
|
|
CdkObserveContent.propDecorators = {
|
|
event: [{ type: i0.Output, args: ['cdkObserveContent',] }],
|
|
disabled: [{ type: i0.Input, args: ['cdkObserveContentDisabled',] }],
|
|
debounce: [{ type: i0.Input }]
|
|
};
|
|
var ObserversModule = /** @class */ (function () {
|
|
function ObserversModule() {
|
|
}
|
|
ObserversModule.ɵfac = function ObserversModule_Factory(t) { return new (t || ObserversModule)(); };
|
|
ObserversModule.ɵmod = /*@__PURE__*/ ɵngcc0.ɵɵdefineNgModule({ type: ObserversModule });
|
|
ObserversModule.ɵinj = /*@__PURE__*/ ɵngcc0.ɵɵdefineInjector({ providers: [MutationObserverFactory] });
|
|
(function () { (typeof ngDevMode === "undefined" || ngDevMode) && ɵngcc0.ɵsetClassMetadata(ObserversModule, [{
|
|
type: i0.NgModule,
|
|
args: [{
|
|
exports: [CdkObserveContent],
|
|
declarations: [CdkObserveContent],
|
|
providers: [MutationObserverFactory]
|
|
}]
|
|
}], function () { return []; }, null); })();
|
|
(function () { (typeof ngJitMode === "undefined" || ngJitMode) && ɵngcc0.ɵɵsetNgModuleScope(ObserversModule, { declarations: [CdkObserveContent], exports: [CdkObserveContent] }); })();
|
|
return ObserversModule;
|
|
}());
|
|
|
|
/**
|
|
* @license
|
|
* Copyright Google LLC All Rights Reserved.
|
|
*
|
|
* Use of this source code is governed by an MIT-style license that can be
|
|
* found in the LICENSE file at https://angular.io/license
|
|
*/
|
|
|
|
/**
|
|
* Generated bundle index. Do not edit.
|
|
*/
|
|
|
|
exports.CdkObserveContent = CdkObserveContent;
|
|
exports.ContentObserver = ContentObserver;
|
|
exports.MutationObserverFactory = MutationObserverFactory;
|
|
exports.ObserversModule = ObserversModule;
|
|
|
|
Object.defineProperty(exports, '__esModule', { value: true });
|
|
|
|
})));
|
|
|
|
//# sourceMappingURL=cdk-observers.umd.js.map
|