func publisher()

in Sources/Confidence/BufferedPassthroughSubject.swift [20:29]

• 10 lines of code
• 1 McCabe index (conditional complexity)

    func publisher() -> AnyPublisher<T, Never> {
        return queue.sync {
            isListening = true
            let bufferedPublisher = buffer.publisher
            buffer.removeAll()
            return bufferedPublisher
                .append(subject)
                .eraseToAnyPublisher()
        }
    }