rxjs-compatibility

    0.0.3 • Public • Published

    rxjs-compatibility

    Convert Observables from RxJS v5 to v4 and vice versa.

    Please upgrade to 100% RxJS v5 ASAP

    This library is meant as a stop gap to help ease migration progressively, not as a band-aid for indefinite interop.

    Install

    This has a peer dependencies of rxjs@5.*.* and rx@4.*.*, which will have to be installed as well.

    npm install --save rxjs-compatibility

    Usage

    Note: this library does not provide automatic interop between the two for cases like ObservableV4.from(v5), v4.flatMap(() => v5), etc. You must explicitly "convert" between the two.

    When you convert from one Observable version to the other, keep in mind that if it's currently in v4 "mode", you'll only have v4 operators until you convert it back to v5 and vice versa. Effectively the result of one is piped into the other, just like how normal operators work.

    Operators

    The most ergonomic way to convert between the two versions is via the included operators patched on both Observable prototypes.

    At some entry point file, you first run this to patch them:

    import { patchObservables } from 'rxjs-compatibility';
     
    patchObservables();

    If you need to customize what Observable prototypes get patched, you can optionally provide them as v4 and v5 arguments:

    patchObservables(ObservableV4, ObservableV5);

    This is usually only neccesary when you're not using CommonJS modules. e.g. UMD builds of v4 and v5 use the same global variable window.Rx so you need to store them elsewhere and then provide them to the patchObservable call.

    stream$.v4()

    Converts the current Observable to a v4 Observable. Exists and works on both v5 Observables and ones that are already v4 too, in which case they just return this.

    RxV5.Observable.of(1, 2, 3)
      .v4()
      .select(num => num + 1)
      .subscribe(value => console.log(value));
     
    // 2, 3, 4

    stream$.v5()

    Converts the current Observable to a v5 Observable. Exists and works on both v4 Observables and ones that are already v5 too, in which case they just return this.

    RxV4.Observable.of(1, 2, 3)
      .v5()
      .map(num => num + 1)
      .subscribe(value => console.log(value));
     
    // 2, 3, 4

    Demo

    You can give it a spin in JSBin: http://jsbin.com/foqara/edit?js,output

    Notice that because JSBin doesn't support a module system and instead uses global variables, you have to provide the Observable classes you want to patch.

    Utility helpers

    If you need to convert an existing observable and don't want to (or can't) patch the prototype, you can use the provided helpers:

    import { toV4, toV5 } from 'rxjs-compatibility';
     
    const v5 = ObservableV5.of(1, 2, 3);
     
    toV4(v5) instanceof ObservableV4;
    // true

    Install

    npm i rxjs-compatibility

    DownloadsWeekly Downloads

    34

    Version

    0.0.3

    License

    MIT

    Last publish

    Collaborators

    • jayphelps