first implementation of fromReadStream with tests

fixes #8

Author: make-github-pseudonymous-again

src/fromReadStream.js

@@ -0,0 +1,16 @@
+import fromAsyncIterable from './fromAsyncIterable' ;
+
+async function* _fromReadStream ( readStream ) {
+
+	for await (const chunk of readStream) {
+		for (const piece of chunk) yield piece ;
+	}
+
+}
+
+/**
+ * Converts a ReadStream object to a stream.
+ * @param {ReadStream} readStream the ReadStream object to convert
+ * @function
+ */
+export default readStream => fromAsyncIterable( _fromReadStream( readStream ) ) ;

src/index.js

@@ -1,47 +1,49 @@
 import EOF from './EOF' ;
 import StreamFromCallable from './StreamFromCallable' ;
 import asyncIterableChain from './asyncIterableChain' ;
-import asyncIterableToArray from './asyncIterableToArray' ;
 import asyncIterableMap from './asyncIterableMap' ;
+import asyncIterableToArray from './asyncIterableToArray' ;
 import chain from './chain' ;
 import exhaust from './exhaust' ;
 import fromArray from './fromArray' ;
 import fromAsyncIterable from './fromAsyncIterable' ;
 import fromCallable from './fromCallable' ;
 import fromIterable from './fromIterable' ;
 import fromIterator from './fromIterator' ;
+import fromReadStream from './fromReadStream' ;
 import fromString from './fromString' ;
 import ignore from './ignore' ;
 import map from './map' ;
 import skip from './skip' ;
 import split from './split' ;
 import toArray from './toArray' ;
-import toCallable from './toCallable' ;
 import toAsyncIterable from './toAsyncIterable' ;
+import toCallable from './toCallable' ;
 import toIterator from './toIterator' ;
 import toString from './toString' ;
 
 export default {
 	EOF ,
 	StreamFromCallable ,
 	asyncIterableChain ,
-	asyncIterableToArray ,
 	asyncIterableMap ,
+	asyncIterableToArray ,
 	chain ,
 	exhaust ,
 	fromArray ,
 	fromAsyncIterable ,
 	fromCallable ,
 	fromIterable ,
 	fromIterator ,
+	fromReadStream ,
 	fromString ,
 	ignore ,
 	map ,
 	skip ,
 	split ,
 	toArray ,
-	toCallable ,
 	toAsyncIterable ,
+	toCallable ,
 	toIterator ,
 	toString ,
 } ;
@@ -50,23 +52,24 @@ export {
 	EOF ,
 	StreamFromCallable ,
 	asyncIterableChain ,
-	asyncIterableToArray ,
 	asyncIterableMap ,
+	asyncIterableToArray ,
 	chain ,
 	exhaust ,
 	fromArray ,
 	fromAsyncIterable ,
 	fromCallable ,
 	fromIterable ,
 	fromIterator ,
+	fromReadStream ,
 	fromString ,
 	ignore ,
 	map ,
 	skip ,
 	split ,
 	toArray ,
-	toCallable ,
 	toAsyncIterable ,
+	toCallable ,
 	toIterator ,
 	toString ,
 } ;

test/data/hello-world.txt

@@ -0,0 +1 @@
+hello, world

test/src/fromReadStream.js

@@ -0,0 +1,24 @@
+import test from 'ava' ;
+import fs from 'fs' ;
+
+import stream from '../../src' ;
+
+test( 'unread token' , async t => {
+
+	const filepath = 'test/data/hello-world.txt' ;
+	const encoding = 'utf8' ;
+	const expected = fs.readFileSync(filepath, encoding);
+
+	const readStream = fs.createReadStream(
+		filepath ,
+		{
+			encoding: encoding ,
+			highWaterMark: 1024 ,
+		}
+	) ;
+
+	const myStream = stream.fromReadStream( readStream ) ;
+
+	t.deepEqual(await stream.toString( myStream ), expected ) ;
+
+} ) ;