subscribe(next, error, complete) {
if (typeof next === "function") {
return this._functionThatThrowsValues({
next,
error: error || () => {},
complete: complete || () => {}
});
}
else {
// pass the observer object
return this._functionThatThrowsValues(next);
}
}