RxJS 5.xでfromを使用してObservableを作成する最も良い方法は？

Question

「lettable」演算子があるので、Observableを別のものから作成するにはどうすればよいですか？

私がやろう：

import {Observable} from 'rxjs/Observable' 
 
const source = Observable.from(someOtherStream)

fromは今個別にインポートする必要が何か他のものであるので、私は、理にかなってエラーObservable.from is not a functionを取得。

私は原因が原型の問題にはもう

import 'rxjs/add/observable/from'を行うにはしたくありません。私がやってしまった何を

た：

import { Observable } from 'rxjs/Observable' 
 
import { from } from 'rxjs/observable/from' 
 

 
const myNewStream = from.call(
 
    Observable, 
 
    someOtherStream 
 
)

しかし、これは本当に私にはいくつかの理由で "ハック" 感じています。誰もこれについてもっと良い方法を持っていますか？

Answer 1

レターテーブルがrxjs/operatorshere's the write up on itの後ろにあります。

fromの場合、Observableをインポートせずにインポートできます。 fromを使用して

import { from } from 'rxjs/observable/from'; 

const prom = new Promise(res => setTimeout(
() => res('promise'), 3000 
)); 

from(prom).subscribe(x => console.log(x)); 

webpackbin example

この方法は、あなたは、賃貸可能事業者にpipe()することができます。

import { from } from 'rxjs/observable/from'; 
import { map } from 'rxjs/operators/map'; 

const prom = new Promise(res => setTimeout(
() => res('promise'), 3000 
)); 

from(prom).pipe(
    map(x => x.split('').reverse().join('')) 
).subscribe(x => console.log(x)); 

webpackbin example

Answer 2

私は、これはfromが何を誤解されると思います。それは、 "ストリーム"（Observable、Promise、array、...）をとり、そこからObservableを作成する単なる関数です。

これはあなただけで、他の関数のようにそれを使用することを意味します：

import { from } from 'rxjs/observable/from' 

from(someOtherStream).pipe(...).subscribe(...)