Mix.install([:kite]) defmodule EverythingEverywhereAllAtOnce do use Kite, endpoint: "wss://jetstream.us-west.bsky.network", kinds: [:commit] def handle_event(payload, _context), do: IO.inspect(payload) end EverythingEverywhereAllAtOnce.start_link([]) Process.sleep(:timer.seconds(60))