如果我GenStage的handle_demand/2方法是这样的: def handle_demand(demand, _state) when demand > 0 do
case Queue.dequeue do
nil ->
Logger.debug("Queue empty.")
{:noreply, [], []}
{job, up
我很感激我的代码任何帮助,我不断收到一个错误 SQL命令无法正常从蟾蜍结束”。 UPDATE GS_MRC_EXISTING GME
SET GME.GROSS_LAST = STC.SALES
WITH STC AS
(
SELECT DISTINCT (DSF.SOLD_TO_CUSTOMER_KEY) AS CUSTS,
SUM (CASE WHEN DSF.NET_P
以下情形:GenStage制作人处理Twitter流(使用Stream API和ExTwitter),并向GenStage使用者提供一组推文(最大需求消费者要求)。消费者然后只是打印它们。 以下问题:我在寻找特定的推文,所以并不总是有新的推文可用。如果GenStage制作者正在返回一个空的事件列表,则消费者将停止询问。有关更多信息,请参阅this issue and José Valims rep