Resultados da pesquisa a pedido "rxjs"
Como obter um serviço de debounce no evento keyup de entrada em angular2 com rxjs
Estou tentando ligar para um serviço no evento de key-up de entrada. O HTML <input placeholder="enter name" (keyup)='onKeyUp($event)'>Abaixo está oonKeyUp() função onKeyUp(event) { let observable = Observable.fromEvent(event.target, ...
Angular 2 - inscrevendo-se no erro Observable.fromEvent: "Destino de evento inválido"
Estou recebendo um erro estranho ao tentar me inscrever em um Observable. Aqui está uma versão diluída do código que apresenta o problema: import {Component, Input, OnInit, ViewChild} from '@angular/core'; import Rx from 'rxjs/Rx'; ...
Inscreva-se em um fluxo com o RxJS e o módulo twitter-stream-api
Ok, então eu sou um iniciante completo com Rx e, infelizmente, muito novo para js e streams em js também. Estou usando isso https://github.com/trygve-lie/twitter-stream-api [https://github.com/trygve-lie/twitter-stream-api]para conectar-se a ...
Como combinar três observáveis do firebase sem perder atualizações dinâmicas
Eu tenho um 3 firebase paralelo requer. E eu preciso me juntar a eles como um único objeto. Código como abaixo: import {Http} from "@angular/http"; import {AngularFireDatabase} from "angularfire2"; import {Thread} from "../model/thread"; import ...
Angular 2 - Encadeando solicitações http
Eu recebo um Observável RxJS de um httpService, que é o http real do Angular. Agora, assim que obtiver um resultado positivo, desejo processar a próxima solicitação http da qual recebothis.retrieve(). Isso é mais ou menos solicitações de ...
O que $ sinal no final do nome da função indica?
Estou verificando um código em que encontro assim import { Observable } from 'rxjs/Rx'; // reducer import { playerRegister, PlayerState } from './player'; export function getPlayer$ (state$: Observable<MyAppState>): Observable<PlayerState> { ...
Subject vs AnonymousSubject
Qual é a diferença entreSubject eAnonymousSubject noRxJS 5? Pesquisei na internet, mas não encontrei nenhuma informação sobreAnonymousSubject. Encontrei um exemplo na web Subject.create(observer, observable);Olhando para o código-fonte rxjs, vi ...
Observável RxJS com função de assinante assíncrona
Estou tentando fazer algo que parece ser direto, mas está se mostrando surpreendentemente difícil. Eu tenho uma função para assinar uma fila RabbitMQ. Concretamente, esta é a função Channel.consume ...
RxJS: ngOnDestroy () do componente angular takeUntil ()
tl; dr: Basicamente, quero me casar com AngularngOnDestroy com os RxjstakeUntil() operador. -- isso é possível? Eu tenho um componente Angular que abre várias assinaturas Rxjs. Eles precisam ser fechados quando o componente é destruído. Uma ...
Obter fluxo observável angular como matriz
Eu tenho lista, que deve simular o fluxo: list = [ {name : 'Str1', age: 10}, {name : 'Str2', age: 10}, {name : 'Str3', age: 10} ];e eu criei umObservable desta lista: Observable.from(this.list).skip(this.currentPage ...