angular - Restituire il risultato di un observable con combineLatest e Rxjs

Desidero ottenere il risultato di un osservabile che sottrae il valore predefinito ogni volta che il valore cambia

Ogni volta che il valore cambia, sottrae il valore predefinito dal nuovo valore inserito nel campo di input

Ad esempio, il valore predefinito è 5.

Inserisco 4 nel c

Continua a leggere →

angular - Come accedere a Rx.Scheduler.immediate tramite rxjs usando SystemJS/Angular2?

Vorrei usare l'ImmediateScheduler di RxJS nel mio progetto Angular2.

Tuttavia, nella mia installazione di RxJS, questo non esiste. Sto usando "rxjs": "5.0.0-beta.12" nel mio package.json, richiesto da Angular 2.1.2.
Guardando nella cartella node_modules/, trovo una cartella 'rxjs' e una cartella 'rx'. L'ImmediateScheduler non fa parte di 'rxjs' ma di 'rx'. Posso trovarlo lì in 'rx/dist/rx.lite.js' o anche in 'rx/ts/rx/rx-lite.ts' come TypeScript, che sto usando.

Cercando di im

Continua a leggere →

typescript - Rxjs: forma abbreviata per creare un observable da un valore o da un observable

Sto usando rxjs con TypeScript. Ho scritto le seguenti due funzioni semplici. Ma penso che rxjs abbia già una funzionalità del genere. rxjs ce l'ha?

export function isObservable(value: any): value is Observable<any> { return value i

Continua a leggere →

typescript - Firebase e RxJS

Ho creato una funzione che ascolta gli eventi di valore:

getUnreadMessages() : Observable<any>{ return new Observable(observer =>{ firebase.database().ref('messages/' + this.userService.getUserID()).on("value", (snapshot : any) =>{ let count = 0; ...some more logic here... observer.next(count); observer.complete(); }, (error) =>{ observer.error(error); }) }) }

Quando il database

Continua a leggere →

angular - gli operatori RXJS non funzionano con firebase

Sto usando gli operatori RXJS con l'observable di Firebase (distinct e filter). Questa è la mia struttura di Firebase qui. Questo è il mio codice:

let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{

Continua a leggere →

javascript - Il modulo Typescript risolve 'rxjs' in modo diverso nello stesso file

Ho passato ore a girare in tondo, quindi è tempo per un'altra domanda oscura.

Sono all'interno di un mono repository lerna, con due sottoprogetti, ProjectA e ProjectB.

ProjectA ha una dipendenza da rxjs, così come

Continua a leggere →

typescript - RxJS6: resettare il flusso dopo il completamento

Ho giocato un po' con RxJS 6. Sto cercando di implementare dragstart, dragmove e dragend. Questo è il codice che ho finora.

import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { takeUntil } from '

Continua a leggere →

typescript - Con RxJs in Angular devo completare solo gli Observables creati nel componente?

Fondamentalmente non sono ancora davvero sicuro riguardo alla pulizia del codice reattivo nei componenti Angular. Le seguenti regole sono corrette e sufficienti?

Le mie regole per un componente reattivo:

• su manuale x.subscribe():

  • se si utilizza x.takeUntil(...) o una costruzione simile, allora nessuna pulizia manuale
  • se x.complete() viene chiamato nell'ambito del componente allora nessuna pulizia manuale
  • altrimenti
    Continua a leggere →

typescript - paginazione rxjs con sottoscrizione a ogni pagina

Stiamo interrogando graphql tramite websocket per avere una sottoscrizione a una lista di entità. Usiamo la paginazione poiché la lista dovrebbe essere scorrevole indefinitamente. Vogliamo anche vedere le modifiche apportate al database in tempo reale nella lista sul front-end.

Questa lista può essere filtrata, ordinata e impaginata.

Abbiamo la classe SelectParams che ci aiuta a fare ciò:

export class S

Continua a leggere →

typescript - Angular 6 Errore usando RxJS: Impossibile leggere la proprietà 'call' di indefinito

Sto cercando di migrare un'app Angular 5 ad Angular 6 e ho questo blocco di codice RxJS che mi lascia perplesso. Ho cercato su Google e letto abbastanza la documentazione di RxJS per sapere che dovrei usare .pipe, ma non riesco proprio a capire la sintassi.

Il codice restituis

Continua a leggere →