Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
Prefix while inclusive, passing values scaffolding.
extension Publisher {
func prefixInclusive(while predicate: @escaping (Output) -> Bool) -> AnyPublisher<Output, Failure> {
flatMap { value -> AnyPublisher<Output, Failure> in
if predicate(value) {
return Just(value)
.setFailureType(to: Failure.self)
.eraseToAnyPublisher()
} else {
fatalError("To be implemented.")
}
}
/**/
.eraseToAnyPublisher()
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment