[ICO]NameLast modifiedSizeDescription
[PARENTDIR]Parent Directory  -  
[DIR]dist.esm/2025-03-12 08:59 -  
[DIR]dist/2025-03-12 08:59 -  
[DIR]types/2025-03-12 08:59 -  
[ ]LICENSE2025-03-12 08:59 1.1K 
[TXT]README.md2025-03-12 08:59 3.8K 
[TXT]filter.d.ts2025-03-12 08:59 70  
[ ]filter.js2025-03-12 08:59 45  
[TXT]flatMap.d.ts2025-03-12 08:59 72  
[ ]flatMap.js2025-03-12 08:59 46  
[TXT]index.d.ts2025-03-12 08:59 29  
[ ]index.js2025-03-12 08:59 44  
[TXT]interval.d.ts2025-03-12 08:59 74  
[ ]interval.js2025-03-12 08:59 47  
[TXT]map.d.ts2025-03-12 08:59 64  
[ ]map.js2025-03-12 08:59 42  
[TXT]merge.d.ts2025-03-12 08:59 68  
[ ]merge.js2025-03-12 08:59 44  
[TXT]multicast.d.ts2025-03-12 08:59 76  
[ ]multicast.js2025-03-12 08:59 48  
[TXT]observable.d.ts2025-03-12 08:59 78  
[ ]observable.js2025-03-12 08:59 49  
[ ]package.json2025-03-12 08:59 1.2K 
[TXT]scan.d.ts2025-03-12 08:59 66  
[ ]scan.js2025-03-12 08:59 43  
[TXT]subject.d.ts2025-03-12 08:59 72  
[ ]subject.js2025-03-12 08:59 46  
[TXT]symbols.d.ts2025-03-12 08:59 72  
[ ]symbols.js2025-03-12 08:59 46  
[TXT]unsubscribe.d.ts2025-03-12 08:59 80  
[ ]unsubscribe.js2025-03-12 08:59 50  
<h1 align="center">
  🕵️‍♀️ observable-fns
</h1>

<p align="center">
  <a href="https://travis-ci.org/andywer/observable-fns" target="_blank"><img alt="Build status" src="https://img.shields.io/travis/andywer/observable-fns/master.svg?style=flat-square"></a>
  <a href="https://www.npmjs.com/package/observable-fns" target="_blank"><img alt="npm version" src="https://img.shields.io/npm/v/observable-fns.svg?style=flat-square"></a>
  <a href="https://bundlephobia.com/result?p=observable-fns" target="_blank"><img alt="Complete bundle size" src="https://badgen.net/bundlephobia/min/observable-fns"></a>
</p>

Light-weight Observable implementation and common toolbelt functions. Based on [`zen-observable`](https://github.com/zenparsing/zen-observable), re-implemented in TypeScript. Zero dependencies, [tree-shakeable](https://bitsofco.de/what-is-tree-shaking/).

The aim is to provide a lean Observable implementation with a small footprint that's fit to be used in libraries as an alternative to the huge RxJS.

Find all the provided functions and constructors in the 👉 [API Documentation](./docs/API.md)

<br>

🧩&nbsp;&nbsp;Composable functional streams

🚀&nbsp;&nbsp;map(), filter() & friends support async handlers

🔩&nbsp;&nbsp;Based on popular [`zen-observable`](https://github.com/zenparsing/zen-observable), re-implemented in TypeScript

🌳&nbsp;&nbsp;Zero dependencies, [tree-shakeable](https://bitsofco.de/what-is-tree-shaking/)

---

## Installation

```
npm install observable-fns
```

## Observable?

An observable is basically a stream of asynchronously emitted values that you can subscribe to. In a sense it is to the event emitter what the promise is to the callback.

The main difference to a promise is that a promise only resolves once, whereas observables can yield values repeatedly. They can also fail with an error, like a promise, and they come with a completion event to indicate that no more values will be send.

For a quick introduction on how to use observables, check out the [zen-observable readme](https://github.com/zenparsing/zen-observable).

```js
import { Observable, multicast } from "observable-fns"

function subscribeToServerSentEvents(url) {
  // multicast() will make the observable "hot", so multiple
  // subscribers will share the same event source
  return multicast(new Observable(observer => {
    const eventStream = new EventSource(url)

    eventStream.addEventListener("message", message => observer.next(message))
    eventStream.addEventListener("error", error => observer.error(error))

    return () => eventStream.close()
  }))
}

subscribeToServerSentEvents("http://localhost:3000/events")
  .filter(event => !event.isStale)
  .subscribe(event => console.log("Server sent event:", event))
```

## Usage

You can import everything you need directly from the package:

```js
import { Observable, flatMap } from "observable-fns"
```

If you write front-end code and care about bundle size, you can either depend on tree-shaking or explicitly import just the parts that you need:

```js
import Observable from "observable-fns/observable"
import flatMap from "observable-fns/flatMap"
```

Functions like `filter()`, `flatMap()`, `map()` accept asynchronous handlers – this can be a big win compared to the usual methods on `Observable.prototype` that only work with synchronous handlers.

Those functions will also make sure that the values are consistently emitted in the same order as the input observable emitted them.

```js
import { Observable, filter } from "observable-fns"

const existingGitHubUsersObservable = Observable.from(["andywer", "bcdef", "charlie"])
  .pipe(
    filter(async name => {
      const response = await fetch(`https://github.com/${name}`)
      return response.status === 200
    })
  )
```

## API

See [docs/API.md](./docs/API.md) for an overview of the full API.

## License

MIT