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.