in MobiusExtras/Source/ConnectableContramap.swift [11:20]
func contramap<NewInput>(_ transform: @escaping (NewInput) -> Input) -> AnyConnectable<NewInput, Output> {
return AnyConnectable { dispatch in
let connection = self.connect(dispatch)
return Connection(
acceptClosure: { connection.accept(transform($0)) },
disposeClosure: connection.dispose
)
}
}