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