如果我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