Observable.create() 函数的参数是否必须明确定义观察者？

Question

我从这里看到这段代码：https://medium.com/@mohandere/rxjs-5-in-5-minutes-1c3b4ed0d8cc

function multiplyByTen(input) {
  var output = Rx.Observable.create(function subscribe(observer) {
    input.subscribe({
      next: (v) => observer.next(10 * v),
      error: (err) => observer.error(err),
      complete: () => observer.complete()
    });
  });
  return output;
}

var input = Rx.Observable.from([1, 2, 3, 4]);
var output = multiplyByTen(input);
output.subscribe(x => console.log(x));
// Result In:
// 10 
// 20 
// 30 
// 40

我只是没看到 multiplyByTen 函数中订阅函数的 "observer" 参数来自哪里？它是否必须明确定义，或者只是一些 "default" 对象被传递给 create 函数，以防它之前没有定义？为什么它在函数内部称为函数 subscribe(observer) ？它会覆盖默认的 .subscribe() 函数还是它也可以是匿名函数？

Answer 1

它只是一个 RxJS 构造，允许您将新值分派给订阅者函数。基本上，这就是 RxJS 设计库的方式。这允许您控制新值的发送。一个用法示例是当您有一些异步操作并且您想要在它具有 resolved/completed 时向订阅者发送一个新值。

您可以在此处阅读有关其工作原理的更多信息：https://www.learnrxjs.io/operators/creation/create.html

另外，在 JsBin 中查看这个简单的同步示例（取自上面的文档 link）

/*
  Create an observable that emits 'Hello' and 'World' on  
  subscription.
*/
const hello = Rx.Observable.create(function(observer) {
  observer.next('Hello');
  observer.next('World');
});

const subscribe = hello.subscribe(val => console.log(val));
// prints.. the follwoing:
// Hello
// World

我上面提到的异步情况在这里描述：（来自官方 RxJS jsBin 示例 - https://jsbin.com/lodilohate/1/edit?js,console）：

// RxJS v6+
import { Observable } from 'rxjs';

/*
  Increment value every 1s, emit even numbers.
*/
const evenNumbers = Observable.create(function(observer) {
  let value = 0;
  const interval = setInterval(() => {
    if (value % 2 === 0) {
      observer.next(value);
    }
    value++;
  }, 1000);

  return () => clearInterval(interval);
});
//output: 0...2...4...6...8
const subscribe = evenNumbers.subscribe(val => console.log(val));
//unsubscribe after 10 seconds
setTimeout(() => {
  subscribe.unsubscribe();
}, 10000);

Observable.create() 函数的参数是否必须明确定义观察者？

Does the parameter of Observable.create() function have to define explicitely an observer?

javascript

subscribe

observable