from

RxJS 5 from

by Echyzen

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.2.1/rxjs.umd.js"></script>
<script src="https://rawgit.com/eu81273/jsfiddle-console/master/console.js"></script>

JavaScript

const source$ = rxjs.from([1,2,3,4,5,6]);
//first value is true, second false
const [evens$, odds$] = source$.pipe(
	rxjs.operators.partition(val => val % 2 === 0)
 )
 
/*
  Output:
  "Even: 2"
  "Even: 4"
  "Even: 6"
  "Odd: 1"
  "Odd: 3"
  "Odd: 5"
*/
const subscribe = rxjs.merge(
 evens$.pipe(
  rxjs.operators.map(val => `Even: ${val}`)
 ),
 odds$.pipe(
  rxjs.operators.map(val => `Odd: ${val}`)
 )
).subscribe(val => console.log(val));