Max Kharandziuk

Fork without end

1

Check a sample below ``` const H = require('highland') const stream = H([1, 2, 3, 4, 5]).map(String) const l = stream.fork() const r = stream.fork() r.take(2).pipe(process.stdout) l.pipe(process.stdout) ``` As a...

Strange behaviour of a forked stream

1

Check the code below: ``` const H = require('highland') const IntervalStream = function(time, value) { return H(function(push, next) { push(null, value) setTimeout( next, time ) }) } const stream =...

Article is here https://gist.github.com/kharandziuk/e823707bf71fba9a4cdf944216773f58 Hope somebody find it useful! The main reason why I'm posting it here is the absence of some practical tutorials

combineLatest

7

Does somebody plan to implement combineLatest(like in Rx)? You can find a visualization http://rxmarbles.com/#combineLatest

It is easy to wrap simple EventEmitter or ReadableStream, but how should I work with something like [busboy](https://github.com/mscdex/busboy). It doesn't implement ReadableStream interface. I finished with code below, but it...

Dynamic piping

7

Is it possible to resolve the problem below with highland.js? Consider a problem: - split file by lines - write lines to a result file - if a result file...

Uncaught TypeError: fs.statSync is not a function

2

my main.js just import the library: `var BCSocket = require('browserchannel').BCSocket;` I compile file with gulpfile below ``` var gulp = require('gulp'), browserify = require('browserify'), del = require('del'), source = require('vinyl-source-stream'),...

Why does documentation say nothing about backend?

3

Pioneer looks quite interesting but there is no examples more complicate then todoMVC. And in the real life my application rely on the backend and the documentation says nothing about...