"use strict";

const pipe = require("@ppstreams/pipe");
const map = require("@ppstreams/map");
const buffer = require("@ppstreams/buffer");

module.exports = function join(joinValue) {
	let firstValueProcessed = false;

	return pipe([
		map((value) => {
			if (firstValueProcessed === false) {
				firstValueProcessed = true;
				return [ value ];
			} else {
				return [ joinValue, value ];
			}
		}),
		buffer()
	]);
};