在中,它说{*}用于匹配任何东西。但是,对于示例命令: <Example> I had a burger for lunch </Example> <ListenFor RequireAppName="BeforeOrAfterPhrase"> [I] drank [a] {*} with [my] {mealtime} </ListenFor>
在我的一个流中,我将每10秒进行一次聚合,并将这些有效负载写入文件共享。我不太清楚如何使用聚合器。.aggregate(a -> a.groupTimeout(10000))// How do i make it collect every 10所以我想每10秒收集一次,而不是等待一个组的所有消息被接收。当我使用grouptimeout时,每10秒将收集到的所有消息发送到nullchannel。