Current section
Files
Jump to
Current section
Files
lib/pulsar/reader/callback.ex
defmodule Pulsar.Reader.Callback do
@moduledoc """
Internal callback module for Pulsar.Reader.
This module handles messages from the consumer and forwards them to the
reader's stream process. It implements the `Pulsar.Consumer.Callback`
behaviour.
"""
use Pulsar.Consumer.Callback
@impl true
def init([stream_pid, reader_ref]) do
send(stream_pid, {:reader_ready, reader_ref, self()})
{:ok, %{stream_pid: stream_pid, reader_ref: reader_ref}}
end
@impl true
def handle_message(message, state) do
send(state.stream_pid, {:pulsar_message, state.reader_ref, self(), message})
{:ok, state}
end
end