This is RxJS v 4. Find the latest version here

Rx.Observable.wrap(fn)

Ⓢ

Wrap the given generator fn into a function that returns an Observable.

Arguments

1. fn (Function): A generator function to wrap.

Returns

(Function): A function once executed, returns an Observable.

Example

var Rx = require('rx');

var fn = Rx.Observable.wrap(function* (val) {
  return yield Rx.Observable.just(val);
});

fn(42).subscribe(
  function (x) { console.log('next %s', x); },
  function (e) { console.log('error %s', e); },
  function () { console.log('completed'); }
);

// => next 42
// => completed

Location

File:

• /src/core/linq/observable/spawn.js

Dist:

• rx.async.js
• rx.async.compat.js
• rx.all.js
• rx.all.compat.js

Prerequisites:

• If using rx.async.js | rx.async.compat.js
  • rx.js | rx.compat.js
  • rx.binding.js
• rx.lite.js | rx.lite.compat.js

NPM Packages:

• rx

NuGet Packages:

• RxJS-All
• RxJS-Async

Unit Tests:

• /tests/observable/spawn.js