Rx la joya oculta de Net

Presentación sobre Reactive Extensions (Rx) en la conferencia DotNetSpain 2016 en Madrid.

1. Edin Kapić SharePoint Practice Lead @ Sogeti Spain e din @edinkapic.com Rx , la joya oculta de NET

2. ¿Rx? Introducción Rx Observables Sujetos Tratamiento de secuencias ¡Rx! Reimaginando nuestro código Rx en en mundo real Más allá de Rx Agenda

3. Senior Architect & SharePoint Practice Lead Edin Kapi ć @ ekapic www.edinkapic.com Presidente Autor

4. ¿ Rx ?

5. Rx (Reactive eXtensions ) es una librería .NET que permite hacer programación reactiva ¿Qué es Rx ? Sí, esto es lo que parece: una anguila eléctrica ( Electrophorus electricus )

6. Un modelo de programación orientado a flujos de datos y la propagación de los cambios https:// en.wikipedia.org/wiki/Reactive_programming ¿Qué es programación reactiva? Esto es un marble diagram (diagrama de canicas)

7. Flujos de datos y Rx API unificada de consumo de datos asíncronos

8. Rx = Observables + LINQ + Schedulers Rx = LINQ-to- Events IEnumerable = Pull , IObservable = Push Analogías útiles

9. La arquitectura de Rx

10. NuGet Rx-Main NET 4+ UWP Windows Phone NuGet RxJS -Main JavaScript NPM Rx Node.js ¿Cómo obtener Rx ? System.Reactive

11. Rx en otras plataformas

12. Rx

13. static void Main ( string [] args ) { IObservable < char > obs = " Hello , world !" . ToObservable ();   obs.Subscribe (x => Console .WriteLine (x ));   Console .ReadLine (); } Hello , world con Rx

14. Secuencia (flujo, stream ) asíncrona de datos Observable namespace System { public interface IObservable < out T> { IDisposable Subscribe ( IObserver <T> observer ); } }

15. El consumidor de una secuencia observable Observer namespace System { public interface IObserver < in T > { void OnCompleted (); void OnError ( Exception error); void OnNext (T value ); } }

16. Un momento, ¿esto no es algo parecido a… … enumerables ? …eventos?

17. Observable versus Enumerable IObservable Subscribe() IObserver OnNext () OnCompleted () OnError () IEnumerable GetEnumerator () IEnumerator Current MoveNext () Reset () 1…2….3…. Observer 1…2….3…. Enumerator OnNext () MoveNext () Push Pull

18. Observable versus Eventos Observable Objetos “de primera” Todo son métodos normales Se pueden hacer consultas históricas Ciclo de vida sencillo basado en IDisposable Evento Difícil de componer varios eventos += -= no es muy amigable No hay histórico de eventos Difícil de controlar el ciclo de vida IObservable = Eventos+++ 1 2 Handler Source Observer Observer Observer

19. Vale, seguimos con Rx …

20. Subject es IObservable y IObserver a la vez Útil para hacer de proxy entre los “clientes” y el “origen” de datos Subject <T> var subject = new Subject < string >(); subject.Subscribe ( value => Console .WriteLine ( value )); subject.OnNext ( "a" ); subject.OnNext ( "b" ); subject.OnNext ( "c" );

21. Tipos de Subjects ReplaySubject <T> BehaviorSubject <T> AsyncSubject <T> Reproduce todos los valores de la secuencia para todos los suscritores Reproduce el último valor de la secuencia Publica el último resultado de la secuencia al acabar Subject.Create ()

22. Ciclo de vida de una suscripción Suscripción var sub = IObservable.Subscribe (…); Fin de suscripción sub.Dispose (); Observable Observer OnNext (1) Subscribe( observer ) Subscription : IDisposable OnNext (2) 1 2

23. Secuencias finitas y los errores Observable Observer OnCompleted () Subscribe( observer ) Subscription : IDisposable OnError ( exception ) 1 2 

24. Creación de secuencias Manualmente Observable.Return Observable.Empty Observable.Never Observable.Range Observable.Create Observable.Generate Observable.Interval Observable.Timer A partir de otras cosas Observable.Start Observable.FromEventPattern Observable.FromAsyncPattern Task.ToObservable IEnumerable.ToObservable

25. Muy bonito, pero no le veo la utilidad

26. Ejemplo : Búsqueda en redes sociales SearchObservable Subscribe() OnNext (x) TwitterSrch FacebookSrch InstagramSrch Observable.Merge () GetResultAsync () GetResultAsync () GetResultAsync () Task <T>. ToObservable () Internet

27. ¿ Qué podemos hacer con las secuencias ? 1 2 2 1 2 1 2 Filtrar Combinar 1 2 3 Mapear 1 2 B Reducir A Where (x== 2) Merge () Select(f(x)) Sum ()

28. Where OfType GroupBy Buffer Window Distinct DistinctUntilChanged Skip Take SkipUntil TakeUntil Operadores LINQ Filtrar Agrupar Valores únicos Partición http://freecontent.manning.com/animated-gifs/? s=reactive-extensions

29. Proyección Select SelectMany 1 2 B A 1 2 A B A Select( x.ToLetter ) Select( x.FromAToLetter )

30. Count , Min, Max, Sum , Average Devuelven un valor escalar First , Last , Single Devuelven un elemento de la secuencia Aggregate , Scan Función de reducción Reducción 1 2 3 Sum ()

31. Un momento, no he visto nada de “secuencias en el tiempo” todavía…

32. Combinar secuencias Concat Switch 1 2 2 1 3 4 3 4 Merge 1 2 3 1 3 4 2 4 1 2 3 3 4 4

33. Schedulers public interface IScheduler { DateTimeOffset Now { get ; } IDisposable Schedule< TState >( TState state , Func < IScheduler , TState , IDisposable > action ); IDisposable Schedule< TState >( TState state , DateTimeOffset dueTime , Func < IScheduler , TState , IDisposable > action ); IDisposable Schedule< TState >( TState state , TimeSpan dueTime , Func < IScheduler , TState , IDisposable > action ); }

34. new Thread (() => { /* do work */ }). Start () ThreadPool.QueueUserWorkItem (_ => { /* do work */ }, null ) Task.Factory.StartNew (() => { /* do work */ }) syncCtx.Post (_ => { /* do work */ }, null ) Dispatcher.BeginInvoke (() => { /* do work */ }) Abstracción de concurrencia s cheduler.Schedule (() => { /* do work */ })

35. La mayoría de las operaciones de Rx usan schedulers Rx y concurrencia

36. Scheduler como parámetro

37. Tipos de schedulers ImmediateScheduler CurrentThreadScheduler NewThreadScheduler EventLoopScheduler HistoricalScheduler ControlScheduler DispatcherScheduler SynchronizationContextScheduler TaskPoolScheduler ThreadPoolScheduler Genéricos Implementados por la plataforma

38. HistoricalScheduler http:// blogs.msdn.com/b/rxteam/archive/2012/06/14/testing-rx-queries-using-virtual-time-scheduling.aspx

39. SubscribeOn Donde se ejecuta el Observable ObserveOn Donde se ejecuta el Observer Cambiando el lugar de la ejecución

40. ¡ Rx !

41. Código que gestiona llamadas asíncronas o eventos Código que manipula secuencias asíncronas de datos ¿ Dónde aplicar Rx ? https:// github.com/AdaptiveConsulting/ReactiveTrader

42. Ejemplo : Sugerencias de búsqueda

43. Rx en el mundo real

44. Ix (Interactive Expressions) Más allá de Rx

45. IQbservable <T> Más allá de Rx

46. Tx Logs y trazas reactivos Más allá de Rx

47. ReactiveUI UI en Xamarin , UWP y WPF con soporte para Rx https:// github.com/reactiveui Más allá de Rx

48. Recursos

49. Código fuente De Rx : https :// github.com/Reactive-Extensions/Rx.NET De esta sesión : https:// github.com/ekapic/Rx-Dns2016 Tutoriales http ://introtorx.com / http:// reactivex.io https :// msdn.microsoft.com/en-us/data/gg577609 Links útiles https:// manning.com/books/reactive-extensions-in-action

50. http://aka.ms/DOTNETT7S5

51. Edin Kapić SharePoint Practice Lead @ Sogeti Spain e din @edinkapic.com http://aka.ms/DOTNETT7S5