funcSubject.js

//   Copyright 2014-2015 François de Campredon
//
//   Licensed under the Apache License, Version 2.0 (the "License");
//   you may not use this file except in compliance with the License.
//   You may obtain a copy of the License at
//
//       http://www.apache.org/licenses/LICENSE-2.0
//
//   Unless required by applicable law or agreed to in writing, software
//   distributed under the License is distributed on an "AS IS" BASIS,
//   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//   See the License for the specific language governing permissions and
//   limitations under the License.

'use strict';


var Rx = require('rx');



/**
 * Create a simple 'function' that is also a RxJS Subject. 
 * Calling the function will be equivalent to calling
 * the 'onNext' method.
 * 
 * example:
 * 
 * var eventHandler = RxReact.EventHandler.create();
 * eventHandler.subscribe(function (val) {
 *   console.log(val);
 * });
 * 
 * eventHandler('hello'); // log hello
 * eventHandler.onNext('world'); // log world
 * 
 */
function create() {
  function subject(value) {
    subject.onNext(value);
  }
  
  for (var key in Rx.Subject.prototype) {
    subject[key] = Rx.Subject.prototype[key];
  }

  Rx.Subject.call(subject);

  return subject;
}

module.exports = {
  create: create
};