index.js (3300B)
1 /** 2 * @license Apache-2.0 3 * 4 * Copyright (c) 2018 The Stdlib Authors. 5 * 6 * Licensed under the Apache License, Version 2.0 (the "License"); 7 * you may not use this file except in compliance with the License. 8 * You may obtain a copy of the License at 9 * 10 * http://www.apache.org/licenses/LICENSE-2.0 11 * 12 * Unless required by applicable law or agreed to in writing, software 13 * distributed under the License is distributed on an "AS IS" BASIS, 14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 15 * See the License for the specific language governing permissions and 16 * limitations under the License. 17 */ 18 19 'use strict'; 20 21 /** 22 * Transform stream. 23 * 24 * @module @stdlib/streams/node/transform 25 * 26 * @example 27 * var stdout = require( '@stdlib/streams/node/stdout' ); 28 * var transformStream = require( '@stdlib/streams/node/transform' ); 29 * 30 * function transform( chunk, enc, clbk ) { 31 * clbk( null, chunk.toString()+'\n' ); 32 * } 33 * 34 * var opts = { 35 * 'transform': transform 36 * }; 37 * var stream = transformStream( opts ); 38 * 39 * stream.pipe( stdout ); 40 * 41 * stream.write( '1' ); 42 * stream.write( '2' ); 43 * stream.write( '3' ); 44 * 45 * stream.end(); 46 * // => '1\n2\n3\n' 47 * 48 * 49 * @example 50 * var transformStream = require( '@stdlib/streams/node/transform' ); 51 * 52 * function transform( chunk, enc, clbk ) { 53 * clbk( null, chunk.toString()+'\n' ); 54 * } 55 * 56 * var opts = { 57 * 'objectMode': true, 58 * 'encoding': 'utf8', 59 * 'highWaterMark': 64, 60 * 'decodeStrings': false 61 * }; 62 * 63 * var factory = transformStream.factory( opts ); 64 * 65 * // Create 10 identically configured streams... 66 * var streams = []; 67 * var i; 68 * for ( i = 0; i < 10; i++ ) { 69 * streams.push( factory( transform ) ); 70 * } 71 * 72 * 73 * @example 74 * var stdout = require( '@stdlib/streams/node/stdout' ); 75 * var transformStream = require( '@stdlib/streams/node/transform' ); 76 * 77 * function stringify( chunk, enc, clbk ) { 78 * clbk( null, JSON.stringify( chunk ) ); 79 * } 80 * 81 * function newline( chunk, enc, clbk ) { 82 * clbk( null, chunk+'\n' ); 83 * } 84 * 85 * var s1 = transformStream.objectMode({ 86 * 'transform': stringify 87 * }); 88 * 89 * var s2 = transformStream.objectMode({ 90 * 'transform': newline 91 * }); 92 * 93 * s1.pipe( s2 ).pipe( stdout ); 94 * 95 * s1.write( {'value': 'a'} ); 96 * s1.write( {'value': 'b'} ); 97 * s1.write( {'value': 'c'} ); 98 * 99 * s1.end(); 100 * // => '{"value":"a"}\n{"value":"b"}\n{"value":"c"}\n' 101 * 102 * 103 * @example 104 * var stdout = require( '@stdlib/streams/node/stdout' ); 105 * var transformStream = require( '@stdlib/streams/node/transform' ); 106 * 107 * function transform( chunk, enc, clbk ) { 108 * clbk( null, chunk.toString()+'\n' ); 109 * } 110 * 111 * var opts = { 112 * 'transform': transform 113 * }; 114 * 115 * var Stream = transformStream.ctor( opts ); 116 * 117 * var stream = new Stream(); 118 * 119 * stream.pipe( stdout ); 120 * 121 * stream.write( '1' ); 122 * stream.write( '2' ); 123 * stream.write( '3' ); 124 * 125 * stream.end(); 126 * // => '1\n2\n3\n' 127 */ 128 129 // MODULES // 130 131 var setReadOnly = require( '@stdlib/utils/define-nonenumerable-read-only-property' ); 132 var transform = require( './main.js' ); 133 var objectMode = require( './object_mode.js' ); 134 var factory = require( './factory.js' ); 135 var ctor = require( './ctor.js' ); 136 137 138 // MAIN // 139 140 setReadOnly( transform, 'objectMode', objectMode ); 141 setReadOnly( transform, 'factory', factory ); 142 setReadOnly( transform, 'ctor', ctor ); 143 144 145 // EXPORTS // 146 147 module.exports = transform;