| 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 |