never - 1

never observable preventing concatenation.

by Huy Le

HTML

<script src="https://npmcdn.com/@reactivex/[email protected]/dist/global/Rx.umd.js"></script>

JavaScript

const never$ = Rx.Observable.never();

const interval$ = Rx.Observable.interval(500);

const completeMessage$ = Rx.Observable.of('Completed!');

const example = Rx.Observable.concat(
		interval$.take(3),  // Emits 0,1,2 then emits complete.
    never$,							// Received completion notification from previous Observable but never emits anything.
    completeMessage$		// Never received completion notification from previous Observable.
	)
  .subscribe(console.log);