RxJS In-Depth - Ben Lesh

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

[@_benlesh]

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]

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

[@_benlesh]

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

[@DeanRadcliffe]

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

[@_benlesh]

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.

[@itsbazyli]

Fantastic explanation of Observables! Thanks!

[@DJazium]

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

[@codeconcept]

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

[@HafizQutaiba]

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

[@f1freak1]

Anyone know if they'll add in Rx.Subject class to Angular 2?

[@Sinewyk]

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]

agreed

[@DeanRadcliffe]

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

[@leebenson]

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?

[@mhelvens]

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.

[@javiasilis]

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.

[@laozi6951]

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

[@DmitryEfimenko]

What presentation tool did he use to create these animations or text greying out? You can see an example of animation around 9.42

[@xgrommx]

Any slides or source codes?

[@ArjunU]

+Denis Stoyanov github.com/jeffbcross/aim

[@jacobbubu]

www.slideshare.net/benlesh1/rxjs-indepth-angularconnect-2015

[@francismazanet2769]

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

[@FelipeCoury]

Any idea which is the editor he's using?

[@SasaMacakanja]

+Felipe Coury he is using Visual Studio Code

[@pioilu]

+Felipe Coury VS Code: code.visualstudio.com/

[@FelipeCoury]

+Sasa Macakanja thanks!

[@FelipeCoury]

+Piotr Ilski thanks!

[@_benlesh]

+Felipe Coury They're correct, it's Visual Studio Code.