obsFilter

obsFilter.js

Rx.Observable.prototype.obsFilter = function (func) {

  		var self = this;

			return Rx.Observable.createWithDisposable(function (o) {

				self.subscribe(function (source) {

					var subject = null;

					source.finallyAction(function() {
						if (subject !== null){
							subject.onCompleted();
							subject = null;
						}
					}).subscribe(function (x) {

						if (func(x)) {
							if (subject === null) {
								subject = new Rx.Subject();
								o.onNext(subject);
							}
							subject.onNext(x);
						} else {
							if (subject !== null) {
								subject.onCompleted();
								subject = null;
							}
						}

					});

				});

			});

		};