purescriptStreamToAff

test.js

'use strict';

exports._collapseStream = function (stream) { // accepts a request
  return function (onError, onSuccess) { // and callbacks
    var buffer = '';
    stream.on('data', (d) => { buffer = buffer + d; });
    stream.on('err', (err) => onError(err));
    stream.on('end', () => onSuccess(buffer));

    // Return a canceler, which is just another Aff effect.
    return function (cancelError, cancelerError, cancelerSuccess) {
      stream.pause(); // cancel the request
      cancelerSuccess(); // invoke the success callback for the canceler
    };
  };
};

test.ps

foreign import _collapseStream :: forall w e. Stream.Readable w e -> EffFnAff e String