Bacon.fromNodeStream

Bacon.fromNodeStream.coffee

fs = require("fs")
Bacon = require("baconjs")

# Bacon.fromNodeStream converts Node.js ReadableStream into an EventStream
Bacon.fromNodeStream = (stream) ->
  Bacon.fromBinder (sink) ->
    listeners = {}
    addListener = (event, listener) ->
      listeners[event] = listener
      stream.on event, listener
    addListener "data", (chunk) -> sink(chunk)
    addListener "end", () -> sink(new Bacon.End())
    addListener "error", (error) -> sink(new Bacon.Error(error))
    -> for event,listener of listeners
         stream.removeListener event,listener

# Example code

toCharStream = (str) -> Bacon.fromArray(str.split(""))

Bacon.fromNodeStream(fs.createReadStream "bacon.md", { encoding: "utf8" })
  .flatMap(toCharStream)
  .bufferWithCount(80)
  .map(".join", "").
  .log()