lib/broadway/noop_acknowledger.ex

defmodule Broadway.NoopAcknowledger do
  @moduledoc """
  An acknowledger that does nothing.

  It must be initialized as:

      acknowledger: Broadway.NoopAcknowledger.init()

  Set automatically on messages that have been acked immediately
  via `Broadway.Message.ack_immediately/1`.
  """

  @behaviour Broadway.Acknowledger

  @doc """
  Returns the acknowledger metadata.
  """
  def init do
    {__MODULE__, _ack_ref = nil, _data = nil}
  end

  @impl true
  def ack(_ack_ref = nil, _successful, _failed) do
    :ok
  end
end