Comparing version
@@ -26,3 +26,3 @@ // Generated by CoffeeScript 1.3.3 | ||
var Source, emit, skip, source, stream, tap; | ||
var Source, emit, pipe, skip, source, stream, tap; | ||
skip = IStream.skip; | ||
@@ -110,2 +110,8 @@ Source = (function() { | ||
}; | ||
pipe = function(src, tgt) { | ||
src = source(src); | ||
return src.tap(function(val) { | ||
return emit(tgt, val); | ||
}); | ||
}; | ||
return stream = { | ||
@@ -117,4 +123,5 @@ IStream: IStream, | ||
tap: tap, | ||
emit: emit | ||
emit: emit, | ||
pipe: pipe | ||
}; | ||
}); |
@@ -87,2 +87,5 @@ // Generated by CoffeeScript 1.3.3 | ||
var tapper; | ||
if (protocol["implements"](ISeq, strm)) { | ||
return strm; | ||
} | ||
if (!protocol["implements"](IStream, strm)) { | ||
@@ -89,0 +92,0 @@ throw new Error('Not a stream'); |
{ | ||
"name": "cosy-lang", | ||
"version": "0.2.1", | ||
"version": "0.2.2", | ||
"description": "cosy language extension library", | ||
@@ -5,0 +5,0 @@ "main": "lib/lang", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
76710
1.08%1135
0.89%