Converting GenStage code to Broadway

maz · November 17, 2024, 1:11am

I’ve been using pure GenStage for my REST API and I want to convert it to Broadway.

How do I get the Producer to queue demand onto the Broadway Processor?

How to initiate the producer.ex handle_demand() callback to get called, so I can make a Message() for the processor?

gist.github.com

https://gist.github.com/mazz/1430a3b695756b52b09dd58ed222e448

broadway.ex

defmodule Markably.UserNotifications.Broadway do
  @moduledoc false
  use Broadway

  alias Broadway.Message

  require Logger

  def start_link(_opts) do
    Broadway.start_link(Markably.UserNotifications.Broadway,

This file has been truncated. show original

controller.ex

defmodule MarkablyWebApi.UserNotificationController do
  use MarkablyWeb, :controller

  alias Markably.Repo
  alias Markably.UpdateMbyUserNotificationsProducer
  alias Markably.UserNotifications
  alias MarkablyWeb.UserAuth

  require Logger

This file has been truncated. show original

producer.ex

defmodule Markably.UpdateMbyUserNotificationsProducer do
  @moduledoc false
  @behaviour Broadway.Producer

  use GenStage

  alias Broadway.Message
  alias Markably.Pipeline.Timing

  def start_link(opts) do

This file has been truncated. show original