Sha256: e869b38358a09bfd46cd646839dd2ed9dbff734035f3f922f64469c7ad87dc10
Contents?: true
Size: 788 Bytes
Versions: 14
Compression:
Stored size: 788 Bytes
Contents
/**
* Creates an observable sequence from a specified subscribe method implementation.
* @example
* var res = Rx.Observable.create(function (observer) { return function () { } );
* var res = Rx.Observable.create(function (observer) { return Rx.Disposable.empty; } );
* var res = Rx.Observable.create(function (observer) { } );
* @param {Function} subscribe Implementation of the resulting observable sequence's subscribe method, returning a function that will be wrapped in a Disposable.
* @returns {Observable} The observable sequence with the specified implementation for the Subscribe method.
*/
Observable.create = Observable.createWithDisposable = function (subscribe, parent) {
return new AnonymousObservable(subscribe, parent);
};
Version data entries
14 entries across 7 versions & 1 rubygems