angular - combineLatest ve Rxjs ile bir observable'ın sonucunu döndürmek
Her değer değiştiğinde varsayılan değeri çıkaran bir gözlemlenebilirin sonucunu almak istiyorum
Her değeri değiştirdiğinizde, giriş alanına girilen yeni değeri varsayılan değerden çıkarır
Örneğin varsayılan değer 5'tir.
Giriş alanına 4 giriyorum
Sonuç 5-4=1 olduğundan, 1'i
DAHA FAZLASI →angular - SystemJS/Angular2 kullanarak rxjs üzerinden Rx.Scheduler.immediate nasıl erişilir?
Angular2 projemde RxJS'ten ImmediateScheduler'ı kullanmak istiyorum.
Ancak, RxJS kurulumumda bu mevcut değil. package.json dosyamda Angular 2.1.2 tarafından gereken "rxjs": "5.0.0-beta.12" sürümünü kullanıyorum.
node_modules/ klasörüne baktığımda bir 'rxjs' klasörü ve bir 'rx' klasörü buluyorum. ImmediateScheduler 'rxjs'in bir parçası değil, 'rx'in bir parçasıdır. Orada 'rx/dist/rx.lite.js' veya hatta TypeScript o
typescript - Rxjs: değer veya observable'dan observable oluşturmanın kısa yolu
Ben rxjs'i TypeScript ile kullanıyorum. Aşağıdaki iki basit fonksiyonu yazdım. Ama sanırım rxjs'in zaten böyle bir işlevi var. rxjs var mı?
export function isObservable(value: any): value is Observable<any> { return value instanceof DAHA FAZLASI →typescript - Firebase ve RxJS
Değer olaylarını dinleyen bir fonksiyon yaptım:
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); }) }) }Veritabanı değiştiğinde, bu
DAHA FAZLASI →angular - RXJS operatörleri firebase ile çalışmıyor
RXJS operatörlerini Firebase gözlemi ile kullanıyorum (distinct ve filter). İşte buradaki Firebase ağacım. İşte kodum:
let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ console.log(p) return p.g DAHA FAZLASI →javascript - Typescript modülü aynı dosyada 'rxjs'i farklı şekilde çözümlüyor
Saatlerce boşuna dolaşıp durdum, o yüzden bir başka anlaşılması zor sorunun zamanı geldi.
Ben, iki alt proje olan ProjectA ve ProjectB ile bir lerna mono repo içindeyim.
ProjectA rxjs'e bağımlıdır, tıpkı Proj
DAHA FAZLASI →typescript - RxJS6: tamamlandıktan sonra akışı sıfırla
Biraz RxJS 6 ile oynuyorum. dragstart, dragmove ve dragend uygulamaya çalışıyorum. Şu ana kadar sahip olduğum kod bu.
import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { takeUntil } from 'rxjs/i DAHA FAZLASI →typescript - Angular'da RxJs ile, sadece bileşende oluşturulan Observables'ları tamamlamam mı gerekiyor?
Temelde Angular bileşenlerindeki reaktif kodun temizlenmesi konusunda hâlâ tam olarak emin değilim. Aşağıdaki kurallar doğru ve yeterli mi?
Bir reaktif bileşen için kurallarım:
manuel olarak x.subscribe():
- Eğer x.takeUntil(...) veya benzeri bir yapı kullanıyorsanız, manuel temizlik gerekmez
- Eğer x.complete() bileşen kapsamında çağrılırsa, manuel temizlik yapılmaz
- aksi takdirde manuel olarak talep üzerine veya n DAHA FAZLASI →
typescript - rxjs her sayfaya abonelik ile sayfalama
Bir dizi varlığa abone olmak için websocket üzerinden graphql sorgusu yapıyoruz. Listenin sonsuz kaydırılabilir olması gerektiğinden sayfalandırma kullanıyoruz. Ayrıca ön uçtaki listede veritabanında yapılan değişiklikleri gerçek zamanlı olarak görmek istiyoruz.
Bu liste filtrelenebilir, sıralanabilir ve sayfalanabilir.
Bunu yapmamıza yardımcı olan SelectParams sınıfımız var:
export class SelectParams { DAHA FAZLASI →typescript - Angular 6 RxJS kullanırken Hata: 'call' özelliği tanımsız olan bir nesneden okunamaz
Angular 5 uygulamasını Angular 6'ya taşımaya çalışıyorum ve beni şaşırtan bir RxJS kod bloğum var. Google'da aradım ve RxJS dokümantasyonunu yeterince okudum ve .pipe kullanmam gerektiğini biliyorum, ama sözdizimini tam olarak anlayamıyorum.
Kod, kullanıcı bir arama giriş alan
DAHA FAZLASI →