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

Question

我从这里遇到了这段代码：https : //medium.com/@mohandere/rxjs-5-in-5-minutes-1c3b4ed0d8ccfunction 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 函数中 subscribe 函数的“观察者”参数来自哪里？它是否必须明确定义，还是只是一些“默认”对象传递给 create 函数，以防它之前未定义？为什么在函数内部调用函数 subscribe(observer)？它会覆盖默认的 .subscribe() 函数还是也可以是匿名函数？

Answer 1

它只是一个 RxJS 构造，允许您将新值分派给订阅者函数。基本上，这就是 RxJS 设计库的方式。这允许您控制新值的分派。使用的一个例子是当你有一些异步操作并且你想在它已经解决/完成时向订阅者发送一个新值。

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

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

/*

  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);