![]() Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/vreg/node_modules/rxjs/_esm2015/internal/operators/ |
import { Subscriber } from '../Subscriber'; import { Notification } from '../Notification'; export function materialize() { return function materializeOperatorFunction(source) { return source.lift(new MaterializeOperator()); }; } class MaterializeOperator { call(subscriber, source) { return source.subscribe(new MaterializeSubscriber(subscriber)); } } class MaterializeSubscriber extends Subscriber { constructor(destination) { super(destination); } _next(value) { this.destination.next(Notification.createNext(value)); } _error(err) { const destination = this.destination; destination.next(Notification.createError(err)); destination.complete(); } _complete() { const destination = this.destination; destination.next(Notification.createComplete()); destination.complete(); } } //# sourceMappingURL=materialize.js.map