defmodule CloudRadio.EventProducer do
  use GenStage
  alias Phoenix.PubSub

  def start_link(events \\ []) do
    GenStage.start_link(__MODULE__, events, name: __MODULE__)
  end

  def init(events) do
    PubSub.subscribe(:stats, "*")
    {:producer, events}
  end

  def handle_demand(demand, events) do
    {to_dispatch, rest} = Enum.split(events, demand)
    {:noreply, to_dispatch, rest}
  end

  def handle_info(event, events) do
    IO.inspect({:noreply, [event], [event | events]})
  end
end