Bitopia/test/Observable/Status.k

promise {
    enum Status { Running, Error, Complete }
    let make_status = lambda (s: Status) {
        return observer {
            switch match s {
                Status.Running {
                    push 1
                }
                Status.Error {
                    push custom_error('Oops!')
                }
                Status.Complete {
                    push Complete
                }
            }
        }
    }
    let sub = lambda (s: Status) {
        return create_promise << lambda (resolve, _) {
            make_status(s) -> subscribe -> Subscriber {
                next: .{ _ --> resolve(Status.Running) },
                error: .{ _ --> resolve(Status.Error) },
                complete: .{ resolve(Status.Complete) }
            }
        }
    }
    for S in Status {
        await t = sub(S)
        assert t is S
    }
}