s-stream

Basic use

As a getter/setter

var s = stream(5);
s(); // 5
s(3);
s(); // 3

Can be observed via .map

var s = stream();

s.map(function(value) {
	// called once with value 'foo'
	// called once more with value 'bar'
});

s('foo');
s('bar');

Map is called immediately if initialized with any value

var s = stream(123);
s.map(function(value) {
	// called with value 123
});

Including undefined

Promises

Streams wait for promise to resolve

var p = new Promise(function(resolve, reject) {
	setTimeout(function() {
		resolve('foo');
	}, 250);
});

var s = stream(p);

s.map(function(value) {
	// called after 250ms with value 'foo'
});

With error handling

var p = new Promise(function(resolve, reject) {
	setTimeout(function() {
		reject(new Error('failed'));
	}, 250);
});

var s = stream(p);

s.map(function(value) {
	// never called
});

s.catch(function(err) {
	// called after 250ms with Error('failed');
});

Preventing memory leaks

Listeners can be removed with .off

var s = stream();
var f = function() {};
s.map(f);
s.off(f);

Other information

stream.toString returns a string of form stream(contentType)

var s = stream(123);
s.toString(); // `stream(Number)`