RxJS In-Depth - Ben Lesh

No video

RxJS In-Depth - Ben Lesh

Рет қаралды 64,524

AngularConnect

Күн бұрын

AngularConnect - The official European Angular conference 2015 - angularconnect.com
Premier sponsor: rangle.io

Пікірлер: 29

@_benlesh 8 жыл бұрын

I paired on the source code with Jeff Cross and Rob Wormald for their talk and mine. It can be found here: Project Source: github.com/jeffbcross/aim RxJS 5: github.com/ReactiveX/RxJS

@DeanRadcliffe 7 жыл бұрын

Ben - the animated gifs comparing the 4-step process with iterables and Observables - where can I get those? Great talk, thanks!

@_benlesh 7 жыл бұрын

Dean Radcliffe... I made those myself. I might still have them, but it's been a while.

@DeanRadcliffe 7 жыл бұрын

Killer illustration - maybe I'll try my hand at that - a little react-motion or somethin :)

@_benlesh 7 жыл бұрын

I think I used D3 to generate it. However if I did it now, is probably just use PowerPoint animations. I've gotten better those. Haha.

@Sinewyk 8 жыл бұрын

I think around 15:00 there's a mistake. He says "if you tell it to stop producing values, that's the producer telling the consumer it knows it's done, so the completion handler won't fire. The completion handler is for when the producer wants to tell the consumer that it's done successfully". I would swap the order producerconsumer the first time it appears for it to make sense. When calling unsubscribe it's the consumer telling the producer "I don't care", so the completion handler is not fired (I think).

@yuzk2 8 жыл бұрын

agreed

@DeanRadcliffe 7 жыл бұрын

Yeah.. There were a few misspeakings in here, he had rewritten a great deal.

@leebenson 7 жыл бұрын

Late response, but I believe the speaker is accurate (at least as of RxJS v5): Example: ``` const err = e => console.log(`Error ${e.message}`); const val = v => console.log(`Value: ${v}`); const done = () => console.log('Done!'); const timer$ = Rx.Observable.interval(500); const u = timer$.subscribe(val, err, done); setTimeout(() => u.unsubscribe(),1500); ``` Unsubscribing after 1500ms won't fire the `done()` callback. However, if we add `.take(1)` to the `timer$` event, then the done callback _does_ fire. Is that what you mean?

@itsbazyli 8 жыл бұрын

Fantastic explanation of Observables! Thanks!

@codeconcept 8 жыл бұрын

Great presentation and comparison of promises vs observables. Plus the honesty in the final advice on not believing in any zero drawback technology :) Thanks !

@DJazium 8 жыл бұрын

Awesome talk. Thinking in Rx has been challenging, so these videos help a ton.

@mhelvens 8 жыл бұрын

I think the term "set" is misleading, and "stream" is definitely the proper term here. The values you get from an Observable are ordered, and not necessarily unique. Good talk, though.

@HafizQutaiba 8 жыл бұрын

Good talk. I need to practice rxjs alot before everything goes down my head...

@francismazanet2769 8 жыл бұрын

If that was in depth, I'd hate to see a summary version.

@laozi6951 8 жыл бұрын

介绍 filter map reduce 的时候，比较了数组操作和流操作的不同

@javiasilis 8 жыл бұрын

I wonder if this technology could be applied to HTML5 videos. This could allow a good way to "stop downloading" the videos ,and reconnecting in case there's a problem.