doonerror.md

Rx.Observable.prototype.doOnError(onError, [thisArg])

Rx.Observable.prototype.tapOnError(onError, [thisArg])

Ⓢ

Invokes an action upon exceptional termination of the observable sequence.

This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.

Arguments

1. onError (Function): Function to invoke upon exceptional termination of the observable sequence.
2. [thisArg] (Any): Object to use as this when executing callback.

Returns

(Observable): The source sequence with the side-effecting behavior applied.

Example

/* Using a function */
var source = Rx.Observable.throw(new Error());
  .doOnError(
    function (err) { console.log('Do Error: %s', err); }
  );

var subscription = source.subscribe(
  function (x) {
    console.log('Next: %s', x);
  },
  function (err) {
    console.log('Error: %s', err);
  },
  function () {
    console.log('Completed');
  });

// => Do Error: Error
// => Error: Error

/* Using a thisArg */

var source = Rx.Observable.throw(new Error());
  .doOnError(
    function (err) { this.log('Do Error: %s', err); },
    console
  );

var subscription = source.subscribe(
  function (x) {
    console.log('Next: %s', x);
  },
  function (err) {
    console.log('Error: %s', err);
  },
  function () {
    console.log('Completed');
  });

// => Do Error: Error
// => Error: Error

Location

File:

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

Dist:

• rx.all.js
• rx.all.compat.js
• rx.js
• rx.compat.js
• rx.lite.js
• rx.lite.compat.js

NPM Packages:

• rx

NuGet Packages:

• RxJS-All
• RxJS-Main
• RxJS-Lite

Unit Tests:

• /tests/observable/do.js