Notícias

RXGO: Extensões reativas para a linguagem Go

by Auto News Bot 19 de agosto de 2023 186

No entanto, no caso de um observável conectável, temos que chamar Connect ():
Depois que o Connect () é chamado, o observável conectável começa a emitir itens.Por outro lado, vamos criar um observável frio usando o operador de adiamento:
Agora, o resultado é:
No caso de um observável frio, o fluxo foi criado independentemente para todos os observadores.No entanto, existem operadores especiais para lidar com erros (por exemplo, OnError, repetir, etc.) Aqui está um exemplo com um observável regular:
Agora, com um observável conectável:
Um iterável é um objeto que pode ser observado usando o observe (opts … opção) <-chan item.Um observável conectável se assemelha a um observável comum, exceto que ele não começa a emitir itens quando é subscrito, mas apenas quando o método Connect () é chamado. Fonte: https://github.com/ReactiveX/RxGo