import Concat from 'ex-stream/Concat';
Concatenate stream data by
_concat
function
import Concat from 'ex-stream/Concat';
import { log } from 'ex-stream/LogStream';
class ConcatArray extends Concat {
constructor(options) {
super({init: [], options});
}
_concat(result, chunk, enc) {
return result.concat([chunk]);
}
}
const concatArray = new ConcatArray();
concatArray.pipe(log()); // [1,2,3,4,5]
concatArray.write(1);
concatArray.write(2);
concatArray.write(3);
concatArray.write(4);
concatArray.end(5);
class ConcatString extends Concat {
constructor(options) {
super({init: '', options});
}
_concat(result, chunk, enc) {
return result + chunk;
}
}
const concatString = new ConcatString();
concatString.pipe(log()); // 'abcde'
concatString.write('a');
concatString.write('b');
concatString.write('c');
concatString.write('d');
concatString.end('e');
Parameters:
options
:Object
- Stream options
Class is abstract
_concat(result: *, data: *, enc: String)
Stream data concatenation method
Parameters:
result
:*
- result of concatenationdata
:*
- data for concatenationenc
:String
- data encoding for concatenation
Returns: *
- result of concatenation