src/index.js
function emitLine() {	
			if(lineQueue.size() > 0)
			{				
				pause();

				sink({line: lineQueue.deq(), resume});
			}
			else if(streamEnd) {
				sink(new Bacon.End());
			}
			else {
				//If we've run out of lines to emit
				readStream.resume();
			}
		}
function emitLine() {	
			if(lineQueue.size() > 0)
			{				
				pause();

				sink({line: lineQueue.deq(), resume});
			}
			else if(streamEnd) {
				sink(new Bacon.End());
			}
			else {
				//If we've run out of lines to emit
				readStream.resume();
			}
		}
function emitLine ( ) { if ( lineQueue . size ( ) > 0 ) { pause ( ) ; sink ( { line : lineQueue . deq ( ) , resume } ) ; } else if ( streamEnd ) { sink ( new Bacon . End ( ) ) ; } else { //If we've run out of lines to emit readStream . resume ( ) ; } }
Emits a line if possible
Emits a line if possible