fetchObservable()

Observable-based Fetch API that automatically refreshes data and notifies subscribers.

Features

• Uses the standard Fetch API.
• Uses Observable syntax from ES Observable proposal.
• Runs in Node and browsers. (BYO Fetch API and Promises polyfills though)

Installation

	npm install --save fetch-observable

Usage

import fetchObservable from "fetch-observable";

// Creates a single observable for one or multiple URLs.
const liveFeed = fetchObservable(
	"http://example.org/live-feed.json", // <-- URL or array of URLs.
	{
		fetch: fetch,  // <-- Replacable fetch implementation.
		refreshDelay: (iteration) => iteration * 1000, // <-- Callback or just integer ms.
		method: "POST" // <-- Basic Fetch API options.
	}
).map((response) => response.json()); // map() resolves Promises.

// Subscribe-syntax of ES Observables activates the observable.
const subscription1 = liveFeed.subscribe({
	next (response) {
		console.dir(response.json());
	},
	error (error) {
		console.warn(error.stack || error);
	}
});

// Multiple subscriptions allowed. They all get the result.
const subscription2 = liveFeed.subscribe({next () {}});

// Observable can be paused and resumed manually.
liveFeed.pause();
liveFeed.resume();

// Observable will be paused automatically when no subscriptions left.
subscription1.unsubscribe();
subscription2.unsubscribe();

Community

Let's start one together! After you ★Star this project, follow me @Rygu on Twitter.

License

BSD 3-Clause license. Copyright © 2015, Rick Wong. All rights reserved.