Oto ostateczna wersja kodu w TypeScript, co wysyła pliki na serwer w częściach. Co tu się dzieje:

1. W funkcji initUpload() wysyłamy do serwera metadane, aby zweryfikować, czy plik nie został wcześniej wgrany. Trzeba jeszcze dodać liczenie SHA-256, a z tym mam trochę obawy, bo film nagrany telefonem może ważyć 2 GB, a wrzucenie całego pliku do pamięci, aby skorzystać z Crypto API (bo chyba strumieniowo się nie da), spowoduje wykrzaczenie się przeglądarki.

2.
  • Odpowiedz
  • Otrzymuj powiadomienia
    o nowych komentarzach

#programowanie #programista15k #angular
Pytanko mam o #rxjs i może ktoś odpowie, powiedzmy przychodzą jakieś dane z API, jakiś skomplikowany obiekt i sobie do stora w reducerze wrzucam pogrupowane dane czyli coś na zasadzie:

{
jakieśElementy1,
jakieśElementy2,
  • 3
  • Odpowiedz
  • Otrzymuj powiadomienia
    o nowych komentarzach

#programowanie #angular #rxjs
Może mi ktoś podpowie czy jest w RxJS operator, który działa na zasadzie debounceTime ale przykładowo jeśli jest w p---u emitów to żeby debounce działał, ale jak minie powiedzmy 10s to niech aktualną wartość na ten moment obsłuży i ten debounce dalej działa.

Przyklad: dostaję mnóstwo updateów z API w ciągu powiedzmy minuty i żeby to zoptymalizować ustawiam debounceTime. Problem jest taki, że
  • 3
  • Odpowiedz
  • Otrzymuj powiadomienia
    o nowych komentarzach

@Dominias: a może spróbuj po prostu setInterval/setTimeout. I gdy ktoś np wystąpi jakieś zdarzenie, resetujesz timer przez clearTimeout/clearInterval i uruchamiasz znów nowy?
  • Odpowiedz
Wlasnie skończyłem czytać. Dodatki: ECMAScript, TypeScript, npm i wstep do RxJS. Generalnie dobrze napisane. Do RxJS chyba mam osobnego e-booka. Tutaj byly podstawy. Jestem zadowolony z tego ebooka. Czas wybrac kolejny ebook :) #angular #typescript #rxjs #ecmascript #javascript
  • 4
  • Odpowiedz
  • Otrzymuj powiadomienia
    o nowych komentarzach

@Mazowia: juz programuje w TypeScript i z uzyciem Angulara od jakiegoś czasu. Raczej czytalem ta ksiazke i poprzednia by usystematyzowac wiedze i dowiedzieć sie czego nie wiem, naostrzyc piłę jak mówi Joel Spolsky :) No i dosyc duzo sie nauczylem takze od poniedzialku juz praktyka :)
  • Odpowiedz
#programowanie #javascript #reactiveprogramming

Co oznacza zapis funkcji w dokumentacji #rxjs?
Chodzi mi dokładnie o zapis funkcji project w mergeMap. Rozumiem, że przyjmuje ona argument i mnożony jest razy 10. A co oznaczają dwa myślniki i pionowa linia na końcu? Dlaczego potrojony jest zapis 10*i? Czy może to nie jest ogólny zapis ale rozpisanie konkretnego przykładu?

https://rxjs-dev.firebaseapp.com/api/operators/mergeMap
z.....6 - #programowanie #javascript #reactiveprogramming

Co oznacza zapis funkcji...

źródło: comment_EAq5JZcVcIRcDoMxL7wCLqawp5aRbAg2.jpg

Pobierz
  • 5
  • Odpowiedz
  • Otrzymuj powiadomienia
    o nowych komentarzach

@ziolo86:
Zapis z myślnikami to pochodna wykorzystania rxjs-marbles do testów jednostkowych. Ta biblioteka pozwala na zapisanie Observable jako stringa, podwójny myślnik to separator elementów w strumieniu danych Observable.

mergeMap ma dwa zadania: dla każdego elementu z źródłowego obserwable wykonuje funkcję przekazaną jako argument, ta funkcja ma zwrócić Observeble | Promise | Array. Następnie mergeMap subskrybuje otrzymane Observable i zwraca scala wyniki tych Observable w jedno wynikowe Obresvable.
Należy pamiętać, że
  • Odpowiedz
Myślniki oznaczają odstęp czasu pomiędzy emitowanymi wartościami a pionowa kreska oznacza zakończenie emitowania czyli complete w obserwerze
  • Odpowiedz
Witamy Was serdecznie Mirki i Mirabelki!

Jako, że to pierwszy post tutaj, to wypada się przedstawić. (͡ ͜ʖ͡▀ )
Jesteśmy DevMeetings i od 8 lat organizujemy bezpłatne warsztaty dla zaawansowanych developerów. Spotkania odbywają się w sobotę przez cały dzień, gdzie już możecie sami stworzyć aplikację przy użyciu nowej technologii. Specjalizujemy się w #frontend #javascript #react #reactjs #angularjs
  • Odpowiedz
  • Otrzymuj powiadomienia
    o nowych komentarzach

#angularjs #javascript #rxjs

Mikri, tworzę apkę w Angularze, gdzie serwisy/komponenty porozumiewają się za pomocą streamów (Obserwery subksrybuja się do Observable..).
Mam problem z przetestowaniem działania. Mam serwis , który odbiera mi dane z API (Observable.fromPromise(this.$hhtp.get...) - i za pomoca ReplaySubject przekazuje je dalej. W innych komponentach w onInit subksrybuje sie do tego subjectu. Wszystko działa ok.
Niestety mam problem z przetestowaniem działania. W teście robiąc coś takiego:
this.$httpBackend.whenGET(
  • 1
  • Odpowiedz
  • Otrzymuj powiadomienia
    o nowych komentarzach