메이크스레드세이프

@frozen
public struct MakeThreadSafe<Upstream> : Publisher where Upstream : Publisher, Upstream.Output : ThreadConfined

스레드에 제한된 객체의 스트림에 대해 receive(on:) 작동하게 하는 출판사입니다.

.threadSafeReference()를 사용하여 생성

GitHub에 표시

  • 발행자로부터 요소를 받을 스케줄러를 지정합니다.

    이 출판사는 업스트림 출판사에서 내보낸 각 값을 ThreadSafeReference 로 변환하고 이를 대상 스케줄러에 전달한 다음 원래 유형으로 다시 변환합니다.

    선언

    스위프트

    public func receive<S>(on scheduler: S) -> DeferredHandover<Upstream, S> where S : Scheduler

    매개변수

    scheduler

    값을 수신할 직렬 디스패치 대기열입니다.

    반환 값

    지정된 스케줄러에 값을 전달하는 출판사입니다.

    GitHub에 표시