Broadway producer for Telegram updates.

Only available when Broadway is loaded.

Usage:

defmodule MyPipeline do
  use Broadway

  def start_link(_opts) do
    Broadway.start_link(__MODULE__,
      name: __MODULE__,
      producer: [
        module: {Hotline.BroadwayProducer, [token: "your-token"]}
      ],
      processors: [default: [concurrency: 5]]
    )
  end

  def handle_message(_, message, _) do
    IO.inspect(message.data)
    message
  end
end