我在玩Akka,我试图在物化之后找出它的灵活性。
这样做的一种方法是使用低级的反应性流API:
但是,您需要定义要发布或订阅的这些点。是否有发布或订阅任意物化流图节点的方法?这应该是可能的,因为物化的流图只不过是参与者的集合。
例如:首先,部署流程图1:~> B ~> C
然后,部署流程图2和3: d ~> B ~> E
我设计了一个由各种DataBlocks组成的复杂数据流。我将一个包发送到流中,并在结束时接收结果。
我和我一起工作
input.Post();
input.Complete();
// and later with
ReceiveAsync();
对于第一个调用,一切正常,但我不知道如何将第二个数据包发送到流程图中。
在图中我还必须使用WriteOnceBlock,这对于调用两次流会有问题吗?
我在和合作。我处理我生成的发送/接收信号的流程图。这些流程图初始化并启动,但它们不会将控制流返回给我的应用程序:
我导入了time
while time.time() < endtime:
# invoke GRC flowgraph for 1st sequence
if not seq1_sent:
tb = send_seq_2.top_block()
tb.Run(True)
seq1_sent = True
if time.time() < en
我的对象或多或少如下所示:
public class Object1
{
public string connectionIn1 { get; set; }
public string connectionIn2 { get; set; }
public string connectionIn3 { get; set; }
public string connectionOut1 { get; set; }
public string connectionOut2 { get; set; }
public string connectionOut3 { g