Wenn handle_demand/2 meine GenStage Methode sieht wie folgt aus: def handle_demand(demand, _state) when demand > 0 do
case Queue.dequeue do
nil ->
Logger.debug("Queue empty.")
{:
Es gibt einen Producer, der durch eine Liste von Werten initialisiert wird. defmodule GenstageExample.Producer do
use GenStage
require Logger
def start_link(initial \\ 0) do
GenSt
ich habe ein beispiel für genstage anwendung, und in seinen verbrauchern muss ich eine verbindung mit redis verwenden. Und ich verstehe nicht, wie ich diese Verbindung an handle_events weitergeben mus
Für selbstlernende Zwecke versuche ich, Elixier zu lernen und meinen Kopf um GenStage Bibliothek zu wickeln. Ich habe die Dokumentation gelesen und habe sie größtenteils bekommen, aber ich habe ein pa