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

Question

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

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

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()

和操作并不是特别有趣，但是是翻译所需要的，让我们可以处理 writer Zero。这不是定义计算表达式的最惯用的方式 - 它不遵循一元结构 - 但它确实有效！在我们可以使用它之前有两个助手：RunZeroRun

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
}