Resultados da pesquisa a pedido "rxjs5"
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 ...
RxJs Ramificação se outra lógica
onSave() { // event handler const save$ = combineLatest(this.configData.data, this.layerService.layerData) .pipe( filter(([configData]) => !_.isEmpty(configData)), take(1), tap(_ => this.loadingService.showLoading()), map(data => ...
Quais são as semânticas dos diferentes sujeitos do RxJS?
A documentação para o tópico é escassa e é difícil descobrir um "ponto de entrada" lá.
Pacote Angular2 2.0.xe Rx 5 beta.12
Atualmente, estou atualizando as dependências do meu projeto que usam os pacotes Angular2 npm e, portanto, os RxJs. Estou atualizando para a versão estável 2.0.2 do angular, que depende do Rx5 beta.12. Para meu aplicativo da web, implanto apenas ...
O SystemJS carrega muitos arquivos para rxjs
Eu tenho o seguintesystemjs.config.js (com base em algum exemplo que encontrei na internet): (function (global) { System.config({ paths: { // paths serve as alias 'js:': 'js/', }, // map tells the System loader where to look for things map: { // ...
Erro de tipo: observable.of não é uma função - [email protected] - [email protected] - angular5
Após atualizar para [email protected] e converter todas as importações, métodos e operadores de RxJS para o novo formulário> 5.5, recebo um erro de tipo no tempo de execução dizendo queObservable.of não é uma função. O mesmo erro ocorre com todos ...
Função "Cancelar inscrição" retorno de chamada / gancho na função Observador "executor"
Estou confuso sobre qual é o objetivo da função "descartar" ou "cancelar a assinatura", que é (opcionalmente) retornada de uma função observável de "executor", assim: const Rx = require('rxjs'); const obs = Rx.Observable.create(obs => { // we ...
Observando encadeamento em RxJS
Estou aprendendo RxJS e Angular 2. Digamos que tenho uma cadeia de promessas com várias chamadas de funções assíncronas, que dependem do resultado anterior, que se parece com: var promiseChain = new Promise((resolve, reject) => { setTimeout(() ...
Como testar uma função que retorna um observável usando intervalos de tempo no rxjs 5?
Por exemplo, eu tenho uma função como esta: export function timeRange(start: number, end: number): Rx.Observable<number> { return Rx.Observable.interval(1000) .map(n => n + start) .take(end - start + 1) }E eu tive um teste de unidade que ...
Como vincular bidirecionalmente meu próprio RxJS Subject a um [(ngModel)]?
Existe uma maneira curta e simples de passar um RxJSSubject [http://reactivex.io/rxjs/class/es6/Subject.js~Subject.html]ouBehaviorSubject [http://reactivex.io/rxjs/class/es6/BehaviorSubject.js~BehaviorSubject.html]a uma diretiva Angular 2 para ...