You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
23 lines
538 B
JavaScript
23 lines
538 B
JavaScript
"use strict";
|
|
|
|
const Promise = require("bluebird");
|
|
const map = require("@promistream/map");
|
|
|
|
const { validateArguments } = require("@validatem/core");
|
|
const required = require("@validatem/required");
|
|
const isFunction = require("@validatem/is-function");
|
|
|
|
module.exports = function mapStream(_spyCallback) {
|
|
let [ spyCallback ] = validateArguments(arguments, {
|
|
spyCallback: [ required, isFunction ]
|
|
});
|
|
|
|
return map((item) => {
|
|
return Promise.try(() => {
|
|
return spyCallback(item);
|
|
}).then(() => {
|
|
return item;
|
|
});
|
|
});
|
|
};
|