f# - 如何评估此 F# 工作流程？

Question

我对 F# 相当陌生，但一直在阅读有关工作流程和计算表达式的内容。从我完成的阅读中，我认为我至少对工作流程的目的和使用工作流程的语法有了基本的了解。然后，我在这里遇到了一个例子:BitWorker Workflow .

我尝试将示例代码复制到本地项目并成功运行。我开始移动一些东西并了解代码的作用，但我仍然无法理解这个工作流程的实际工作原理。我还没有看到其他示例，其中工作流语法如下:do bitWriter stream {... 而不是 doworkflow {...。

let stream = new IO.MemoryStream()

// write TCP headers
do bitWriter stream {
    do! BitWriter.WriteInt16(12345s)           // source port
    do! BitWriter.WriteInt16(12321s)           // destination port
    do! BitWriter.WriteInt32(1)                // sequence number
    do! BitWriter.WriteInt32(1)                // ack number
    do! BitWriter.WriteInt32(2, numBits = 4)   // data offset
    do! BitWriter.WriteInt32(0, numBits = 3)   // reserved
}

我没想到 stream 会成为 bitWriter 工作流程的一部分。这里使用stream对于工作流程意味着什么？

Answer 1

如果我们看一个实现这样的工作流程的最小示例，这应该更容易解释。首先，我将为您可以执行的操作定义一个类型。为了简单起见，我们只看一个:

type Operation =  
  | WriteInt32 of int

典型的 F# 计算构建器不采用任何构造函数参数，但您实际上可以采用参数 - 此处的计算构建器采用流作为参数并创建一个 StreamWriter。在Bind 操作中，参数是我们的Operation 值之一，我们通过将该值写入流写入器来处理该值。然后我们只需使用 f ()

调用其余的计算

type BitWriter(stream:IO.Stream) = 
  let wr = new IO.StreamWriter(stream)
  member x.Bind(op, f) = 
    match op with
    | WriteInt32 i -> wr.Write(i)
    f ()
  member x.Zero() = ()
  member x.Run( () ) = wr.Dispose()

Zero 和 Run 操作并不是特别有趣，但是 Zero 是翻译和 Run 所必需的让我们处理掉这位作家吧。这不是定义计算表达式的最惯用的方式 - 它不遵循单子(monad)结构 - 但它确实有效!在我们可以使用它之前有两个助手:

let writeInt32 i = WriteInt32 i
let bitWriter stream = BitWriter(stream)

现在您可以编写与上述库几乎相同的代码:

let stream = new IO.MemoryStream()

bitWriter stream {
  do! writeInt32 1
  do! writeInt32 2
  do! writeInt32 3
}