Example of using streams

grab.js

var fs = require('fs');
var express = require('express');
var spawn = require('child_process').spawn;
var icecast = require('icecast');

// URL to a known Icecast stream
var url = 'http://ice.somafm.com/spacestation';

// connect to the remote stream
icecast.get(url, function (res) {

    // log the HTTP response headers
    console.error(res.headers);

    var file, old;

    // log any "metadata" events that happen
    res.on('metadata', function (metadata) {
        var parsed = icecast.parse(metadata);
        console.log('Now playing', parsed.StreamTitle);
        if (file) {
            old = file;
            res.unpipe(old);
        }
        file = fs.createWriteStream('./' + parsed.StreamTitle + '.mp3', {
            flags: 'a',
            mode: 0666
        });
        res.pipe(file);
        if (old) {
            old.end();
        }
    });

    var ff = fs.createWriteStream('./stream.mp3', {
        flags: 'a',
        mode: 0666
    });
    res.pipe(ff);
});