如何从功能上创建可观察？

Question

我想调用一个函数（同步），然后使用它的返回值作为初始发射（随后链接一些其他运算符上的结果可观察）。

我想在订阅期间调用这个函数，所以我不能只使用Observable。（）=

我唯一能想到的是：

Observable.create((observer: Observer<void>) => {
  let val = getSomeValue();
  observer.next(val);
  observer.complete();
})

我想正是这样。但对于一件简单的事情来说，这似乎太复杂了，它本应该是可以观察到的。fromFunction（）=




Answer 1

实际上，我认为最好的选择是使用Observable。创建，因为它是同步和异步初始值的最通用解决方案。

如果确定要使用同步函数，则可以使用startWith（）运算符（只有当getSomeValue（）的返回值对于所有观察者都应相同时，这才有意义）。

使用可观察。bindCallback作为源代码的可观察性当然是可行的，但是我个人建议避免它，因为它会使代码很难理解，而且通常不需要，因为您可以只使用可观察性。创建。

Answer 2

我在项目中使用的fromFunction$的实现：

function fromFunction$<T>(factory: () => T): Observable<T> {
    return Observable.create((observer: Subscriber<T>) => {
        try {
            observer.next(factory());
            observer.complete();
        } catch (error) {
            observer.error(error);
        }
    });
}

用法如下：

fromFunction$(() => 0).subscribe((value) => console.log(`Value is '${value}'`), null, () => console.log('Completed'));
fromFunction$(() => [1, 2, 3]).subscribe((value) => console.log(`Value is '${value}'`), null, () => console.log('Completed'));
fromFunction$(() => { throw 'Something' }).subscribe(null, (error) => console.error(`Error: ${error}`));

给予：

Value is '0'
Completed

Value is '1,2,3'
Completed

Error: Something

直到这种实施存在。

Answer 3

我倾向于尽可能避免任何显式使用Observable.create，因为通常它是一个错误的来源，不仅要管理您的事件发布，还要管理您的拆卸逻辑。

您可以使用Observable。改为推迟。它接受一个函数，该函数返回一个可观察的或一个可观察的类似的东西（读：Promise、Array、Iterators）。因此，如果您有一个返回异步内容的函数，那么很容易：

Observable.defer(() => doSomethingAsync());

如果要使其与同步结果一起工作，请执行以下操作：

Observable.defer(() => Observable.of(doSomethingSync()));

注意：像create一样，这将在每个订阅上重新运行该函数。这与可观察的结果不同。bindCallback，它存储函数调用结果而不重新执行函数。因此，如果您需要这种行为，则需要使用适当的多播操作符。