0回答
builder.add(new SomeTickProcesser(item)) ~> }
ClosedShape有没有办法将我的图形转换成Future-like，然后使用Await等待它结束？或者也许有更好的方法来组织这里的队列？
浏览 3提问于2017-12-02得票数 4
我希望用Flink替换我的基于Akka Streams的流处理器的一部分。cosmosDB -> Evaluate Flow -> Write Flow -> Logger Flow -> Sink
lazy private val converterGraph: Graph[ClosedShape.typesource.watchTermination()(Keep.none) ~> prepareFlow ~> readFlow ~> evaluateFlow ~> writeFlow ~> lo
浏览 2提问于2019-04-24得票数 1
1回答
我正在使用Alpakka播放文件中的Akka流和流内容。我需要在一段时间后停止流，所以我想使用KillSwitch，但是我不知道如何使用它，因为我使用的是图形DSL。._
})
我在这里找到了一个解决方案：
但是，如果我使用的是图形DSL，我不知道如何应用它
浏览 0提问于2017-04-22得票数 3
回答已采纳
1回答
中的这个代码片段说明了如何以编程方式触发元素流： zip.out ~> Flow[(Message, Trigger)].map { case (msg, trigger) => msg } ~> sink
ClosedShape
浏览 4提问于2016-12-29得票数 0
回答已采纳
我有Akka流，这是从文件读取使用alpakka，处理数据和写入一个文件。我希望在处理n个元素后停止流，计算持续时间和呼叫系统终止时间。我怎样才能做到这一点？._
})
你有什么主意吗？谢谢
浏览 3提问于2017-04-23得票数 3
回答已采纳
2回答
我可以创建一个源代码，运行流，然后创建一个文件，但是ByteString不会被写入到文件中。然而，如果我试图打印流输出到控制台，我可以这样做。我是不是漏掉了什么？
浏览 3提问于2016-09-19得票数 2
我创建了一个akka流，它有一个进程函数和一个传递给它的错误处理函数。Source和Sink完全封装在ClosedShape RunnableFlow中。我的意图是将一个项传递给父类并在流中运行它。由于Source和Sink是完全封装的，所以我没有明确的方法让测试等待，并且在所有项都通过流处理之前，它就会到达断言/ way语句。我创建了来描述流。
浏览 0提问于2016-02-19得票数 4
回答已采纳
1回答
我正在尝试构建一个包含一个简单循环的Akka流。在阅读了文档之后，我尝试将示例代码作为起始库复制，但这也不起作用。代码编译(在包含了示例中缺少的源代码之后)，但没有输出任何内容。{ActorMaterializer, ActorMaterializerSettings}import akka.stream.ClosedShapeconcat <~ bcast
zip.in1 <~ concat <~
浏览 5提问于2016-03-04得票数 0
回答已采纳
我试图在Sharepoint设计器上创建一个工作流。工作流应该等到开箱即用的审批工作流完成.这是通过从项目的创建开始我的工作流并设计wait活动来完成的：
等待InternalApproval等于16
有什么简单的方法来解决这个问题吗？我想实现一个繁忙的等待，但如何实现(有一个
浏览 4提问于2009-09-13得票数 2
回答已采纳
1回答
是否有可能在线程池中启动异步工作流，并且，在稍后的某个时间点()等待它的完成，类似于启动一个Task，然后调用Result？我知道启动异步工作流并同时等待它是可能的。关键是决定等待它稍后完成。
浏览 1提问于2015-09-03得票数 2
回答已采纳
2回答
如何停止可运行图
、、
从阿克卡流开始我的第一步。broadcast.out(0) ~> sharedDoubler ~> topHS.in ClosedShape
浏览 6提问于2017-11-01得票数 0
回答已采纳
Sink.fromSubscriber(reactiveConnection.publish()))
当我关闭流时，我还需要关闭以下连接：reactiveConnection是否有在流关闭时调用的方法?比如onComplete()或onClose(
浏览 2提问于2017-11-27得票数 0
回答已采纳
在现在的服务中，工作流活动中的“等待完成”是如何工作的？
这是否意味着它将等待任务被标记为“活动”假？还是等待任务状态“完成”？
浏览 3提问于2015-06-05得票数 1
回答已采纳
5回答
DATA_STEP); } }有没有一种方法可以使主机线程空闲，然后等待某个流完成，然后准备并运行另一个流？编辑:我在代码中添加了while(true)，以强调忙碌的等待。现在我执行所有的流，并检查它们中的哪一个完成了运行另一个新的流。cudaStreamSynchronize等待特定的流完成，但我想<em
浏览 4提问于2011-02-25得票数 3
回答已采纳
2回答
因此，我的问题是，当量角器开始测试我的angularJS应用程序时，它一直在等待完成事件流请求，因为我使用的是ignoreSynchronization=false，所以量角器等待，直到超时作为事件流http请求永远不会完成。所以我想教我的量角器忽略这样的事件流$http任务，并对我的应用程序进行测试。这些事件流是在我的应用程序的整个过程中实现的，所以每次都有事件流请求，然后量角器得到超时。超时时会遇到以下错误:失败:超时等待
浏览 4提问于2017-06-05得票数 2
回答已采纳
= "US") ~> internationalFilter ~> merge.in(1) ClosedShape但正如你在上面看到的，我没有未使用的流量。= "US") ~> internationalFilter ~> merge.in(1)
merge.out ~>
浏览 1提问于2017-09-12得票数 0
回答已采纳
我正在尝试在某人更改字段后将其登录到我的列表中：阶段:如果当前列表设置财务:财务部分是否完成？等于是将财务管理器设置为%Current List:Modified By% Log Financial节完成者：[%Cur...到工作流历史记录列表电子邮件金伯利Abaid过渡到阶段转到等待它
阶段:如果当前项目，请等待:系统部分是否
浏览 18提问于2017-03-17得票数 0
我们试图在不使用PMCMD命令的情况下在Informatica中完成工作流A之后触发工作流B，这可以使用事件等待任务来完成吗？工作流A的最后一步是电子邮件任务。
浏览 4提问于2021-09-08得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
