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.