Sha256: 5a5c05e44435636f14ea7fef1fd52187bb9781ef8717eaa552ec9ab87fbf17f6
Contents?: true
Size: 1.84 KB
Versions: 7
Compression:
Stored size: 1.84 KB
Contents
/*global define: true EventSource: true */
define(['riffle'], function (riffle) {
'use strict';
return function streams(serverUri, ajaxUri) {
var stream = riffle.stream
, me
, serverEvents
, ajaxEvents
, matching
, toJson
, each
, stringEvents
, allEvents
, eventToString
;
serverEvents = stream(function (o, i) {
new EventSource(serverUri).addEventListener('message', o);
}).invoke();
function ajaxStream(url, args) {
return stream(function (o) {
$.get(url, args, function (d) {
o(JSON.parse(d));
});
});
}
eventToString = stream(function (o, i) {
o(i.data);
});
matching = function (regex) {
return stream(function (o, i) {
if (i.match(regex)) { o(i); }
});
};
toJson = stream(function (o, i) {
o(JSON.parse(i));
});
each = stream(function (o, i) {
i.forEach(function (item) { o(item); });
});
function batched(delay, maxSize) {
var batch = []
;
delay = delay || 100;
return stream(function (o, i) {
batch = batch.concat(i);
function clear() {
batch.length > 0 && o(batch);
batch = [];
}
if (maxSize && batch.length > maxSize) {
clear();
} else {
setTimeout(clear, delay);
}
});
}
stringEvents = eventToString.input(serverEvents);
ajaxEvents = each.input(ajaxStream(ajaxUri).invoke());
allEvents = stream().input(stringEvents, ajaxEvents);
return me = {
message: matching(/^message:/).input(stringEvents)
, start: matching(/^status:start/).input(stringEvents)
, stop: matching(/^status:stop/).input(stringEvents)
, example: batched().input(toJson.input(matching(/^\{/).input(allEvents)))
};
};
});
Version data entries
7 entries across 7 versions & 1 rubygems