update to work with ws instead of websocket-server

[neonstalwart]

No description provided.

[neonstalwart]

I don't think streaming is working like it should. i want to try something tomorrow since ws sockets support streaming.

[neonstalwart]

@kriszyp is it possible to apply backpressure to forEach?

using the following code

when(jsgiApp(request), function(response){
    when(response.body, function(body){
        console.log('reading body...');
        when(body.forEach(function (data) {
            var dfd = require('./promise').defer();
            console.log('sending data', data);
            socket.send(data);
            setTimeout(function () {
                console.log('resolving', data);
                dfd.resolve();
            }, 300);
            return dfd.promise;
        }), function () {
            console.log('done');
        });
    });
});

i see this output

reading body...
sending data {}&&
sending data [
sending data {"status":403,"headers":{"vary":"Accept","content-type":"message/json; charset=UTF-8"},"body":{}}
sending data ]
done
resolving {}&&
resolving [
resolving {"status":403,"headers":{"vary":"Accept","content-type":"message/json; charset=UTF-8"},"body":{}}
resolving ]

i was hoping that i could return a promise from forEach and cause the next iteration to wait on the resolution of that promise. is there anything like that?

[neonstalwart]

if there's no way to apply backpressure then this is probably as good as it gets so feel free to merge if you're ok with it.

[kriszyp]

Merged the commits, will take a look at back-pressure later.