Operator Subject

gistfile1.js

var sub = new Rx.Subject();
var obs = sub.distinctUntilChanged(); // This is what I want


function module1(sub) {
    sub.subscribe(console.log.bind(console));

    sub.onNext('hello');
}

function module2(sub) {
    obs.subscribe(console.debug.bind(console));

    sub.onNext('hello');
}


module1(sub);
module2(sub);

// I'd like to pass a subject to various modules that will publish and subscribe but I want operators applied before the subject is passed to the module so that when the module subscribes the operators are already applied.