rxjs5

    1热度

    2回答

    我正在使用带打字稿的rxjs。我写了以下两个简单的函数。但我想rxjs已经有这样的功能。 rxjs? export function isObservable(value: any): value is Observable<any> { return value instanceof Observable; } export function createObservable<T

    1热度

    1回答

    在重试时,我能够在失败时重新执行http请求,就像RxJs Observables: run retryWhen after some more async requests中的示例一样。我希望ajax(..)在失败后重新输入新选项。假设我想在第一次http请求失败后更改标头或网址。任何示例?

    1热度

    1回答

    我创建了一项服务,它使用RxJS来包装$http调用。 我有几个组件订阅相同的observable,我希望他们共享AJAX结果,而不是多个请求。 服务代码: export function SearchService($http) { 'ngInject'; const autocompleteResults$ = new Subject() .debounceT

    0热度

    1回答

    我有2类,为MyService和FooComponent,如下所示: class MyService { getStuff(): Observable<Any>() { //Implementation that may take sometime to return } } class FooComponent { private myServic

    0热度

    1回答

    我有这样的史诗: export const fetchProductsFulfilledEpic = action$ => action$.ofType(FETCH_PRODUCTS_FULFILLED) .mergeMap(action => { return Observable.of( updateSearchResults(action.paylo

    0热度

    1回答

    我有一个Angular(4)中的情况异步管道没有绑定到ngAfterViewInit()中设置的Observable,除非我使用Observable.interval(1000)在构造函数中初始化它。如果我删除了.interval-部分,则当ngAfterViewInit()运行时,异步管道将不会订阅观察值。 我想初始化的观像这样在类的顶部,但打破了功能: resultStream: Observ

    -1热度

    1回答

    我有角度(4)应用程序,我正在使用EventEmitter的某些事件。 因此,每个eventEmitter约有约50个订阅。我想知道如何快速消灭他们。 1)我知道我们将每个Observable/Subject对象推送到数组的方式,但它确实很脏。我们的应用程序中有很多丑陋的代码,当我看到它时,我的眼睛正在流血。 2)我知道另一种方式,当我们可以使用.takeUntil或.takeWhile但它不是解

    0热度

    1回答

    如何在rxjs中使用Observables实现以下代码? 我想在这里实现的是,我有一个函数数组,每个函数接受一个对象,修改它并将对象返回到堆栈中的下一个函数。 function A(res:SomeType){ //Do Something return res; } function B(res:SomeType){ //Do Something r

    8热度

    3回答

    我有一个RxJS5管道看起来像这样 Rx.Observable.from([2, 3, 4, 5, 6]) .takeWhile((v) => { v !== 4 }) 我想保持订阅,直到我看到4,但我想也应该包括在结果最后一个元素4 。所以上面的例子应该是 2, 3, 4 然而,根据official document,takeWhile操作者是不包括在内。这意味着当它遇到与我们

    2热度

    1回答

    比方说,我有一个sequence这样的: Rx.Observable .interval(1000) .subscribe(data => {console.log(data)}) 随着operators,我怎么能 'restart' 的顺序,意味着unsubscribe和resubscribe。 真正的情况是,sequence是一个套接字流,当我们需要unsubscribe和resubs