@@ -31,18 +31,6 @@ var constantStream = require( './../lib' );
31
31
32
32
// FUNCTIONS //
33
33
34
- /**
35
- * Callback invoked upon encountering an error.
36
- *
37
- * @private
38
- * @param {Error } error - error
39
- * @param {integer } [code] - exit code
40
- */
41
- function onError ( error , code ) {
42
- process . exitCode = code || 1 ;
43
- console . error ( 'Error: %s' , error . message ) ; // eslint-disable-line no-console
44
- }
45
-
46
34
/**
47
35
* Callback invoked once a source stream ends.
48
36
*
@@ -79,16 +67,19 @@ function main() {
79
67
} )
80
68
} ) ;
81
69
70
+ // Get any provided command-line options:
71
+ flags = cli . flags ( ) ;
72
+ if ( flags . help || flags . version ) {
73
+ return ;
74
+ }
75
+
82
76
// Get any provided command-line arguments:
83
77
args = cli . args ( ) ;
84
78
if ( args . length < 1 ) {
85
79
err = new Error ( 'insufficient arguments. Must provide a value to stream.' ) ;
86
80
return onError ( err ) ;
87
81
}
88
82
89
- // Get any provided command-line flags:
90
- flags = cli . flags ( ) ;
91
-
92
83
opts = { } ;
93
84
if ( flags . iter ) {
94
85
opts . iter = parseInt ( flags . iter , 10 ) ;
@@ -102,6 +93,17 @@ function main() {
102
93
stream . on ( 'end' , onEnd ) ;
103
94
104
95
stream . pipe ( stdout ) ;
96
+
97
+ /**
98
+ * Callback invoked upon encountering an error.
99
+ *
100
+ * @private
101
+ * @param {Error } error - error
102
+ * @param {integer } [code] - exit code
103
+ */
104
+ function onError ( error , code ) {
105
+ cli . error ( error , code || 1 ) ;
106
+ }
105
107
}
106
108
107
109
main ( ) ;
0 commit comments