Mau*_*kye 4 f# types asynchronous timeout matching
我正在编写一个异步方法,该方法应该异步查询端口,直到找到一个端口,或者在 5 分钟后超时;
member this.GetPort(): Async<Port> = this._GetPort(DateTime.Now)
member this._GetPort(startTime: DateTime): Async<Port> = async {
match this._TryGetOpenPort() with
| Some(port) -> port
| None -> do
if (DateTime.Now - startTime).TotalMinutes >= 5 then
raise (Exception "Unable to open a port")
else
do! Async.Sleep(100)
let! result = this._GetPort(startTime)
result}
member this._TryGetOpenPort(): Option<Port> =
// etc.
Run Code Online (Sandbox Code Playgroud)
然而,我在_GetPort;中遇到了一些奇怪的类型不一致。该函数表示我正在返回类型Async<unit>而不是Async<Port>。
这有点不直观,但是让你的代码工作的方法是这样的:
member private this.GetPort(startTime: DateTime) =
async {
match this.TryGetOpenPort() with
| Some port ->
return port
| None ->
if (DateTime.Now - startTime).TotalMinutes >= 5 then
raise (Exception "Unable to open a port")
do! Async.Sleep(100)
let! result = this.GetPort(startTime)
return result
}
member private this.TryGetOpenPort() = failwith "yeet" // TODO
Run Code Online (Sandbox Code Playgroud)
我冒昧地清理了一些东西并将成员设置为私有,因为这似乎是您在这里主要追求的,通过更详细的内部方式来获取端口。
您的代码未编译的原因是您的计算结果不一致return:
Some(port)您缺少return关键字 - 需要将值恢复为Async<port>if提出异常的表达式有一个else分支,但你不是return来自两个分支。在这种情况下,由于您显然不希望返回任何内容而只是引发异常,因此您可以省略else并使其成为命令式程序流,就像在非异步代码中一样。您可能希望考虑的另一件事是抛出异常是否是您想要的,或者仅返回一个Result<T,Err>或一个选项是否是正确的调用。异常本质上并不是坏事,但如果有一种好的方法可以将含义赋予包装返回值的类型,则通常许多 F# 编程都会避免使用异常。
| 归档时间: |
|
| 查看次数: |
151 次 |
| 最近记录: |