Buffered subscribing, batched outputting in Combine.

buffered_subscribing_batched_outputting.swift

extension Sequence where Element: Publisher {
	func bufferedSubscribe(by size: Int) -> AnyPublisher<[Element.Output], Element.Failure> {
		publisher
			.flatMap(maxPublishers: .max(size)) { $0 }
			.collect(size)
			.eraseToAnyPublisher()
	}
}