Initializer

init(upstream:createSubject:)

Creates a multicast publisher that applies a closure to create a subject that delivers elements to subscribers.

Declaration

init(upstream: Upstream, createSubject: @escaping () -> SubjectType)

Parameters

createSubject

A closure that returns a Subject each time a subscriber attaches to the multicast publisher.