Kotlin Channels & Flow

Transcript

2. Jeziel Lago /jeziellago @jeziellago Android Developer | PicPay
3. Kotlin Channels & Flow
4. vamos dar uma olhada em Java… 4 Antes de falar de Kotlin Channels,
6. BlockingQueue 6 java.util.concurrent.BlockingQueue
9. Channel 9 BlockingQueue
10. 10 Channels
11. Channels 11
12. Channels 12
13. 13 Tipos de Channels
15. 15 Rendezvous Channel Channel sem buffer Uma das funções (send ou receive) sempre fica suspensa até que a outra seja chamada.
16. 16 Unlimited Channel Channel com buffer "ilimitado" Os producers podem enviar elementos para esse canal, e ele crescerá infinitamente. A chamada de envio nunca será suspensa. Se não houver mais memória, você receberá uma OutOfMemoryException
17. 17 Conflated Channel Devolve sempre o elemento mais recente
18. 18 Buffered Channel Channel com buffer de tamanho fixo Os producers podem enviar elementos para este canal até que o limite de tamanho seja atingido. Quando o buffer estiver cheio, a próxima chamada de envio será suspensa até que apareça mais espaço livre. O tamanho do buffer é 64 por padrão mas pode ser substituído pela configuração DEFAULT_BUFFER_PROPERTY_NAME via JVM
19. 19 Na prática….
20. 20 Qual a saída esperada?
21. 21 Qual a saída esperada? launch1 launch2 channel launch3
22. 22 Qual a saída esperada? launch1 launch2 channel launch3 send “A1"
23. 23 Qual a saída esperada? launch1 launch2 channel launch3 send “A1" send “B1”
24. 24 Qual a saída esperada? launch1 launch2 channel launch3 send “B1” receive “A1”
25. 25 Qual a saída esperada? launch1 launch2 channel launch3 A1 send “B1” println(“A1”)
26. 26 Qual a saída esperada? launch1 launch2 channel launch3 A1 receive “B1”
27. 27 Qual a saída esperada? launch1 launch2 channel launch3 A1, B1 println(“B1”)
28. 28 Qual a saída esperada? launch1 launch2 channel launch3 A1, B1 send “A2”
29. 29 Qual a saída esperada? launch1 launch2 channel launch3 A1, B1 send “A2” send “B2”
30. 30 Qual a saída esperada? launch1 launch2 channel launch3 A1, B1 send “B2” receive “A2”
31. 31 Qual a saída esperada? launch1 launch2 channel launch3 A1, B1, A2 send “B2” println(“A2”)
32. 32 Qual a saída esperada? launch1 launch2 channel launch3 A1, B1, A2 receive “B2”
33. 33 Qual a saída esperada? launch1 launch2 channel launch3 A1, B1, A2, B2 println(“B2”)
34. 34 Qual a saída esperada? launch1 launch2 channel launch3 A1, B1, A2, B2
35. 35 Qual a saída esperada? launch1 launch2 channel launch3
36. 36 Qual a saída esperada? launch1 launch2 channel launch3 send “A1”
37. 37 Qual a saída esperada? launch1 launch2 channel launch3 Buffer = [“A1”]
38. 38 Qual a saída esperada? launch1 launch2 channel launch3 Buffer = [“A1”] send “A2”
39. 39 Qual a saída esperada? launch1 launch2 channel launch3 Buffer = [“A1”,“A2”]
40. 40 Qual a saída esperada? launch1 launch2 channel launch3 Buffer = [“A1”,“A2”] send “B1”
41. 41 Qual a saída esperada? launch1 launch2 channel launch3 Buffer = [“A1”,“A2”,”B1”]
42. 42 Qual a saída esperada? launch1 launch2 channel launch3 Buffer = [“A1”,“A2”,”B1”] send “B2”
43. 43 Qual a saída esperada? launch1 launch2 channel launch3 Buffer = [“A1”,“A2”,”B1”,”B2”]
44. 44 Qual a saída esperada? launch1 launch2 channel launch3 Buffer = [“A2”,”B1”,”B2”] receive “A1”
45. 45 Qual a saída esperada? launch1 launch2 channel launch3 A1 Buffer = [“A2”,”B1”,”B2”] println(“A1”)
46. 46 Qual a saída esperada? launch1 launch2 channel launch3 A1 Buffer = [”B1”,”B2”] receive “A2”
47. 47 Qual a saída esperada? launch1 launch2 channel launch3 A1, A2 Buffer = [”B1”,”B2”] println(“A2”)
48. 48 Qual a saída esperada? launch1 launch2 channel launch3 A1, A2 receive “B1” Buffer = [”B2”]
49. 49 Qual a saída esperada? launch1 launch2 channel launch3 A1, A2, B1 Buffer = [”B2”] println(“B1”)
50. 50 Qual a saída esperada? launch1 launch2 channel launch3 A1, A2, B1 receive “B2” Buffer = []
51. 51 Qual a saída esperada? launch1 launch2 channel launch3 A1, A2, B1, B2 Buffer = [] println(“B2”)
52. 52 Qual a saída esperada? launch1 launch2 channel launch3 A1, A2, B1, B2
53. 53 Channels podem ser fechados para indicar que não há mais elementos chegando.
54. 54 ClosedReceiveChannelException: Channel was closed println(5) Channel Conflated emite o item mais recente
55. 55 Channel & Coroutines Coroutine builder + channel + extension functions Producers Consumers
56. 56 1. Channels são ótimos para modelar fontes de dados quentes Algumas considerações… 2. Deve-se usar um channel quando precisar enviar dados de uma coroutine para outra a) coroutines são concorrentes b) precisamos de sincronização para trabalhar com qualquer dado na presença de concorrência.
57. 57 Mas e se não precisarmos de concorrência ou sincronização, mas apenas de fluxos de dados sem bloqueio?
58. 58 Sejam bem-vindos ao Kotlin Flow!
59. 59 Um flow é um stream “frio” de valores myFlow é apenas a referência da instância do Flow O código dentro do flow{…} não está ativo e ainda não há recursos vinculados a ele.
60. 60 Flow possui duas operações principais Flow emit(…) collect{…}
61. 61 Algumas maneiras de criar um Flow flow{…} flowOf(…) .asFlow()
62. 62 Flows podem ser transformados usando alguns operadores
63. 63 Alguns listeners de “eventos”
64. 64 Coroutine context & Flow Use flowOn para especificar o contexto de execução.
65. 65 Coroutine context & Flow Use flowOn para especificar o contexto de execução. Trecho executado com Dispatchers.IO
66. 66 Coroutine context & Flow Use flowOn para especificar o contexto de execução. Trecho executado com Dispatchers.Default
67. 67 Coroutine context & Flow Use flowOn para especificar o contexto de execução. Trecho executado no contexto de quem chamar o collect
68. 68 Exemplos
69. 69 Exemplos
70. 70 Wrapping callbacks com callbackFlow
71. 71 Wrapping callbacks com callbackFlow
72. 72 Wrapping callbacks com callbackFlow
73. 73 Wrapping callbacks com callbackFlow
74. 74 Wrapping callbacks com callbackFlow
75. 75 Wrapping callbacks com callbackFlow
76. 76 …mas e testes?
78. 78 Considerações Finais ✍ Channel & Flow podem andar juntos Migração tranquila de RxJava/RxKotlin/RxAndroid para Channel & Flow Nova versão do Room e WorkManager já tem suporte para Flow API ainda Experimental
79. 79 Dúvidas?
80. Jeziel Lago /jeziellago @jeziellago Android Developer | PicPay Obrigado!
81. 81 Links http://tutorials.jenkov.com/java-util-concurrent/blockingqueue.html https://medium.com/@elizarov/reactive-streams-and-kotlin-flows-bfd12772cda4 https://medium.com/@elizarov/simple-design-of-kotlin-flow-4725e7398c4c https://medium.com/@elizarov/execution-context-of-kotlin-flows-b8c151c9309b https://medium.com/@elizarov/cold-flows-hot-channels-d74769805f9#9f07 https://proandroiddev.com/what-is-concurrent-access-to-mutable-state-f386e5cb8292 https://play.kotlinlang.org/hands-on/Introduction%20to%20Coroutines%20and%20Channels/01_Introduction https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/-flow/