Fazer ThreadSafe
@frozen
public struct MakeThreadSafe<Upstream> : Publisher where Upstream : Publisher, Upstream.Output : ThreadConfined
Um editor que faz receive(on:)
funcionar para fluxos de objetos confinados a threads
Criar usando .threadSafeReference()
-
Especifica o agendador no qual receber elementos do editor.
Esse editor converte cada valor emitido pelo editor upstream em um
ThreadSafeReference
, passa para o agendador de destino e converte de volta para o tipo original.Declaração
Swift
public func receive<S>(on scheduler: S) -> DeferredHandover<Upstream, S> where S : Scheduler
Parâmetros
scheduler
A fila de despacho em série para receber valores.
Valor de retorno
Um editor que fornece valores ao agendador fornecido.