console.clear();

​

console.log('first():');

​

let subscription1 = Rx.Observable.interval(1000).first().subscribe();

​

console.log('closed before calling unsubscribe?: ' + subscription1.closed);

​

subscription1.unsubscribe();

​

console.log('closed after calling unsubscribe?: ' + subscription1.closed);

​

console.log('----------------');

​

console.log('take(1):');

​

let subscription2 = Rx.Observable.interval(1000).take(1).subscribe();

​

console.log('closed before calling unsubscribe?: ' + subscription2.closed);

​

subscription2.unsubscribe();

​

console.log('closed after calling unsubscribe?: ' + subscription2.closed);

​