RxJS: AsyncSubject, BehaviorSubject and ReplaySubject

rxjs-subjects.js

var subjectAsync = new Rx.AsyncSubject();
var subscriptionAsync = subject.subscribe(
    value => console.log(`My Value is ${value}`),
    err => console.log(`Error message: ${err}`),
    () => console.log('Completed!')
)

var counterAsync = 5,
    interval = setInterval(()=>{
        subject.next(counter--);
        if(!counter){
            clearInterval(interval);
            subject.complete()
        }
    }, 1000);