ObservableKPartial

Swift

public static func map<A, B>(
    _ fa: ObservableKOf<A>,
    _ f: @escaping (A) -> B) -> ObservableKOf<B>

Swift

public static func pure<A>(_ a: A) -> ObservableKOf<A>

Swift

public static func flatMap<A, B>(
    _ fa: ObservableKOf<A>,
    _ f: @escaping (A) -> ObservableKOf<B>) -> ObservableKOf<B>

Swift

public static func tailRecM<A, B>(
    _ a: A,
    _ f: @escaping (A) -> ObservableKOf<Either<A, B>>) -> ObservableKOf<B>

Swift

public typealias E = Error

Swift

public static func raiseError<A>(_ e: Error) -> ObservableKOf<A>

Swift

public static func handleErrorWith<A>(
    _ fa: ObservableKOf<A>,
    _ f: @escaping (Error) -> ObservableKOf<A>) -> ObservableKOf<A>

Swift

public static func foldLeft<A, B>(
    _ fa: ObservableKOf<A>,
    _ b: B,
    _ f: @escaping (B, A) -> B) -> B

Swift

public static func foldRight<A, B>(
    _ fa: ObservableKOf<A>,
    _ b: Eval<B>,
    _ f: @escaping (A, Eval<B>) -> Eval<B>) -> Eval<B>

Swift

public static func traverse<G: Applicative, A, B>(
    _ fa: ObservableKOf<A>,
    _ f: @escaping (A) -> Kind<G, B>)
    -> Kind<G, ObservableKOf<B>>

Swift

public static func `defer`<A>(_ fa: @escaping () -> ObservableKOf<A>) -> ObservableKOf<A>

Swift

public static func asyncF<A>(
    _ procf: @escaping (@escaping (Either<Error, A>) -> Void)
    -> ObservableKOf<Void>) -> ObservableKOf<A>

Swift

public static func continueOn<A>(_ fa: ObservableKOf<A>, _ queue: DispatchQueue) -> ObservableKOf<A>

Swift

public static func runAsync<A>(_ fa: @escaping ((Either<ForObservableK.E, A>) -> Void) throws -> Void) -> ObservableKOf<A>

Swift

public static func runAsync<A>(
    _ fa: ObservableKOf<A>,
    _ callback: @escaping (Either<Error, A>) -> ObservableKOf<Void>)
    -> ObservableKOf<Void>

Swift

public static func race<A, B>(
    _ fa: ObservableKOf<A>,
    _ fb: ObservableKOf<B>) -> ObservableKOf<Either<A, B>>

Swift

public static func parMap<A, B, Z>(
    _ fa: ObservableKOf<A>,
    _ fb: ObservableKOf<B>,
    _ f: @escaping (A, B) -> Z) -> ObservableKOf<Z>

Swift

public static func parMap<A, B, C, Z>(
    _ fa: ObservableKOf<A>,
    _ fb: ObservableKOf<B>,
    _ fc: ObservableKOf<C>,
    _ f: @escaping (A, B, C) -> Z) -> ObservableKOf<Z>

Swift

public static func runAsyncCancellable<A>(
    _ fa: ObservableKOf<A>,
    _ callback: @escaping (Either<ForObservableK.E, A>)
    -> ObservableKOf<Void>) -> ObservableKOf<BowEffects.Disposable>

Swift

public static func bracketCase<A, B>(
    acquire fa: ObservableKOf<A>,
    release: @escaping (A, ExitCase<Error>) -> ObservableKOf<Void>,
    use: @escaping (A) throws -> ObservableKOf<B>) -> ObservableKOf<B>