js-libp2p/src/util/index.js
2020-01-24 14:40:40 +01:00

17 lines
326 B
JavaScript

'use strict'
/**
* Converts BufferList messages to Buffers
* @param {*} source
* @returns {AsyncGenerator}
*/
function toBuffer (source) {
return (async function * () {
for await (const chunk of source) {
yield Buffer.isBuffer(chunk) ? chunk : chunk.slice()
}
})()
}
module.exports.toBuffer = toBuffer