asset-pipe-js-reader - npm Package Compare versions

lib/reader.js

		@@ -43,23 +43,29 @@ 'use strict';
		const merged = mergeStream();
		let count = 0;
		streams.forEach((strm) => {
		strm.on('error', (error) => {
		this.emit('error', error);
		});
		strm.on('file found', (file) => {
		this.emit('file found', file);
		merged.add(strm.pipe(JSONStream.parse('*')));
		count++;
		if (count === streams.length) {
		if (merged.isEmpty()) {
		this.emit('pipeline empty');
		} else {
		this.emit('pipeline ready');
		}
		}
		});
		strm.on('file not found', (file) => {
		this.emit('file not found', file);
		count++;
		if (count === streams.length) {
		if (merged.isEmpty()) {
		this.emit('pipeline empty');
		} else {
		this.emit('pipeline ready');
		}
		}
		});
		});

		// If the merged file stream yelded empty, we can not continue
		setImmediate(() => {
		if (merged.isEmpty()) {
		return this.emit('pipeline empty');
		}
		this.emit('pipeline ready');
		});

		// Set up the pipeline
		@@ -81,3 +87,4 @@ const order = new Order();
		.pipe(this);

		}
		};

package.json

Improved metrics