Light Observable

An implementation of Observables for JavaScript. Requires a Promise polyfill.

This is a fork of zen-observable. Some of extras are inspired by observable-operators.

Features:

• Standard: fully compatible with the Observable Proposal.
• Tiny: Observable itself is only 973 bytes in gzip (including symbol-observable package).
• Type-safe: written in typescript.
• Reliable: 100% code coverage.
• Moderate: only standard methods are included to the Observable and Observable prototype + special Observable.prototype.pipe method that allows usage of pipeable operators.

Differences from zen-observable

• Uses symbol-observable polyfill instead of own implementation.
• Subscribing and iterating over arrays in .of and .from methods are synchronous.
• PartitialObserver allows a start method, which will receive a subscription before calling the source.

Extras

• pipe: an utility to pipe functions together

  import { pipe } from 'light-observable'
  import { from } from 'rxjs'
  import { mergeMap } from 'rxjs/operators'
  
  import myStream from './myStream'
  
  const RxStream = pipe(
    from,
    mergeMap(...)
  )(myStream)

• createSubject: an utility that returns a tuple of an observable stream and a controller sink.

  import { createSubject } from 'light-observable'
  const [stream, sink] = createSubject()
  
  stream.subscribe(console.log)
  sink.next(1) // > 1
  sink.next(2) // > 2

• EMPTY: represents an empty Observable, which completes right after subscribing
• Bunch of pipeable operators: filter, map, forEach, merge, tap, throttle etc.

Install

npm install light-observable

Usage

import { Observable } from 'light-observable'

const o = new Observable(observer => {
  observer.next(1)
  observer.next(2)
  observer.complete()
})

o.subscribe(console.log)
// > 1
// > 2

Why

Because sometimes you just don't need all these tons of classes, dozens of schedulers and countless operators. Only some of them. Someday.

Notice on interoperability

RxJS 6 doesn't use 'symbol-observable' polyfill. This may cause some weird issues with interop depending on the import order. It is recommended to install and import symbol-observable polyfill before RxJS.

See the issue for details.

License

Copyright 2018 Tinkoff Bank

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.