gpt4 book ai didi

Akka Streams Graph DSL 表示法

转载 作者:行者123 更新时间:2023-12-02 09:28:15 26 4
gpt4 key购买 nike

我使用 graph dsl 根据我看到的一些示例代码创建了一些流处理作业。一切运行良好,我只是无法理解符号:(针对 2.4 更新)

def elements: Source[Foos] = ...
def logEveryNSink = // a sink that logs
def cleaner: Flow[Foos, Bars, Unit] = ...

def boolChecker(bar: Bar)(implicit ex: ExecutionContext): Future[Boolean] = ...

val mySink = Sink.foreach[Boolean](println(_))

val lastly = Flow[Bars].mapAsync(2)(x => boolChecker(x).toMat(mySink)(Keep.right)

val materialized = RunnableGraph.fromGraph(
GraphDSL.create(lastly) { implicit builder =>
baz => {
import GraphDSL.Implicits._
val broadcast1 = builder.add(Broadcast[Foos](2))
val broadcast2 = builder.add(Broadcast[Bars](2))
elements ~> broadcast1 ~> logEveryNSink(1)
broadcast1 ~> cleaner ~> broadcast2 ~> baz
~> broadcast2 ~> logEveryNSink(1)
ClosedShape
}
}
).run()

我理解包含的隐式构建器,但我不确定 baz{ implicit builder => baz => { ... 中代表什么。它只是整个形状的隐式名称吗?

最佳答案

GraphDSL.create 方法被大量重载以接收输入形状数量的许多变体(包括 0)。如果您不传入任何初始形状,则 buildBlock 函数 arg 的签名(您实际定义图形构建方式的主体)如下所示:

(Builder[NotUsed]) => S

所以这只是一个 Function1[Builder[NotUsed], S],也就是说,一个函数接受一个 Builder[NotUsed] 的实例并返回一个Shape 实例,即最终图形。这里的 NotUsedUnit 的同义词,因为您是在说通过不传递任何输入份额,您不关心正在生成的输出图的物化值。

如果您确实决定传入输入形状,那么 buildBlock 函数的签名会稍作更改以适应输入形状。在您的例子中,您传入了 1 个输入形状,因此 buildBlock 的签名更改为:

(Builder[Mat]) => Graph.Shape => S

现在,这本质上是一个 Function1[Builder[Mat], Function1[Graph.Shape, S]],或者一个采用 Builder[Mat] 的函数(其中 Mat 是输入形状的物化值类型)并返回一个函数,该函数采用 Graph.Shape 并返回 S 的实例(这是一个 Shape)。

长话短说,如果你传入形状,那么你还需要将它们声明为图形构建 block 函数的绑定(bind)参数,但作为第二个输入函数(因此附加 =>)。

关于Akka Streams Graph DSL 表示法,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35691116/

26 4 0