fix build hang

src/nodes/Merger.js

@@ -104,6 +104,10 @@ export default class Merger extends Node {
 		this._active = false;
 	}
 
+	active () {
+		return this._active;
+	}
+
 	_cleanup ( index ) {
 		const dir = join( session.config.gobbledir, this.id );
 

src/nodes/Observer.js

@@ -139,4 +139,8 @@ export default class Observer extends Node {
 		this.input.stop();
 		this._active = false;
 	}
+
+	active () {
+		return this._active;
+	}
 }

src/nodes/Source.js

@@ -126,6 +126,10 @@ export default class Source extends Node {
 		this._active = false;
 	}
 
+	active () {
+		return this._active;
+	}
+
 	_findCreator ( filename ) {
 		try {
 			statSync( filename );

src/nodes/Transformer.js

@@ -159,6 +159,10 @@ export default class Transformer extends Node {
 		this._active = false;
 	}
 
+	active () {
+		return this._active;
+	}
+
 	_cleanup ( latest ) {
 		const dir = join( session.config.gobbledir, this.id );
 

src/nodes/build/index.js

@@ -39,7 +39,8 @@ export default function ( node, options ) {
 			.then(
 				inputdir => copydir( inputdir ).to( dest ),
 				err => { throw err; }
-			);
+			)
+			.then(() => node.stop());
 	}
 
 	promise = cleanup( gobbledir )

test/build.js

@@ -1,42 +1,48 @@
 var assert = require( 'assert' ),
 	path = require( 'path' ),
 	sander = require( 'sander' ),
-
-	sample = new RegExp( '^' + path.join( __dirname, 'sample' ) ),
-	output = path.join( __dirname, 'output' );
+	gobble = require( '../tmp' ).default;
+	sample = new RegExp( '^' + path.join( __dirname, 'sample' ) );
 
 module.exports = function () {
 	describe( 'node.build()', function () {
 		beforeEach( function () {
-			// Clean up output dir
-			return sander.rimraf( 'output' );
+			return sander.rimraf( 'tmp' ).then( function () {
+				return sander.copydir( 'sample' ).to( 'tmp' );
+			});
 		});
 
 		afterEach( function () {
-			// Clear cache of sample build definitions
-			Object.keys( require.cache ).forEach( function ( mod ) {
-				if ( sample.test( mod ) ) {
-					delete require.cache[ mod ];
-				}
-			});
-
-			// Clean up output dir
-			return sander.rimraf( 'output' );
+			return sander.rimraf( 'tmp' );
 		});
 
-		it( 'should return a promise that fulfils on completion of build', function () {
-			return require( './sample/foo' ).build({
-				dest: output
+		it( 'should return a promise that fulfills on completion of build', function () {
+			return gobble( 'tmp/foo' ).build({
+				dest: 'tmp/output'
 			}).then( function () {
-				return sander.readFile( output, 'foo.md' ).then( function ( data ) {
+				return sander.readFile( 'tmp/output', 'foo.md' ).then( function ( data ) {
+					assert.equal( data.toString().trim(), 'foo: this is some text' );
+				});
+			});
+		});
+
+		it( 'should stop completion of build', function () {
+			var node = gobble( 'tmp/foo' );
+			var task = node.build({
+				dest: 'tmp/output'
+			});
+			return task.then( function () {
+				assert.equal(node.active(), false);
+
+				return sander.readFile( 'tmp/output', 'foo.md' ).then( function ( data ) {
 					assert.equal( data.toString().trim(), 'foo: this is some text' );
 				});
 			});
 		});
 
 		it( 'should throw an error if no `dest` is specified', function () {
 			assert.throws( function () {
-				require( './sample/foo' ).build();
+				gobble( 'tmp/foo' ).build();
 			}, function ( err ) {
 				return err.code === 'MISSING_DEST_DIR';
 			});