lib/jetstream/consumer.ex at main

comet.sh / drinkup

fork atom

Elixir ATProtocol ingestion and sync library.

fork atom

drinkup / lib / jetstream / consumer.ex

at main 11 lines 273 B view raw

wrap content

ovyerus.com refactor: integrate consumers and sockets directly 6w ago

ff43b49a

 1defmodule Drinkup.Jetstream.Consumer do
 2  @moduledoc """
 3  Behaviour for handling Jetstream events.
 4
 5  Implemented by `Drinkup.Jetstream`, you'll likely want to be using that instead.
 6  """
 7
 8  alias Drinkup.Jetstream.Event
 9
10  @callback handle_event(Event.t()) :: any()
11end