import { NextObserver } from 'rxjs/internal/types' ; export class MutableObserver < T > implements NextObserver < T > { private nextCallback : ( value : T ) => void = ( ) => { } ; public setNext ( next ) { this . nextCallback = next ; } public next ( value ) { return this . nextCallback ( value ) ; } }