foo.js

// Using anon functions
var source = self;
return new AnonymousObservable(function (o) {
    return source.subscribe(
        function (x) { o.onNext(x); },
        function (e) { o.onError(e); },
        function () { o.onCompleted(); })
});

// Using binders
function bindOnNext(o) {
    return function (x) { o.onNext(x); };
}

function bindOnError(o) {
    return function (e) { o.onError(e); };
}

function bindOnCompleted(o) {
    return function () { o.onCompleted(); };
}

// Using anon functions
var source = self;
return new AnonymousObservable(function (o) {
    return source.subscribe(
        bindOnNext(o),
        bindOnError(o),
        bindOnCompleted(o))
});