@rxjsx/rxjsx v1.0.0

RxJS Extensions

RxJS operators to deal with arrays, tuples, and dragging the original values along while adding more values to the pipeline.

:hammer_and_wrench: Install

npm install --save @rxjsx/rxjsx rxjs

:technologist: Demo

import { of } from 'rxjs';
import { flatListMap } from '@rxjsx/rxjsx';

of([1, 2, 3], [4], [5, 6])
    .pipe(flatListMap(x => of(x, 10+x)))
    .subscribe(console.log);

You can experiment with the above code by forking this ReplIt repo or through this Medium article.

:open_book: Examples

// instead of this
of([1, 2, 3]).pipe(map(l => l.map(e => e * 2))

// you can do this
of([1, 2, 3]).pipe(listMap(e => e * 2)) // [2, 4, 6]

// instead of this
let device;
deviceService.getDevice(id)
  .pipe(tap(_device => device = _device))
  .pipe(flatMap(_device => userService.getUser(device.owner)))
  .pipe(map(_user => userService.unassignDevice(_user, _device)))

// you can do this
deviceService.getDevice(id)
  .pipe(flatZipMap(device => userService.getUser(device.owner)))
  .pipe(map(([device, user]) => userService.unassignDevice(user, device)))

:notebook: Manual

The available operators so far are the following:

:muscle: Thanks to all Contributors

:books: Related Literature

• 13 Handy RxJS Operators to Deal with Arrays and Tuples

:keyboard: Contributing

• CONTRIBUTING.md

:pray: Support

This project needs your support. Don't forget to leave a :star: behind.