Internal callback module for Pulsar.Reader.
Implements the Pulsar.Consumer.Callback behaviour, forwarding messages to the reader's
stream process, and hosts the flow policy that reports what each delivery cost.
Summary
Functions
Callback implementation for Pulsar.Consumer.Callback.became_active/1.
Callback implementation for Pulsar.Consumer.Callback.became_passive/1.
Callback implementation for Pulsar.Consumer.Callback.handle_call/3.
Callback implementation for Pulsar.Consumer.Callback.handle_cast/2.
Callback implementation for Pulsar.Consumer.Callback.handle_info/2.
Callback implementation for Pulsar.Consumer.Callback.handle_invalid_message/2.
Flow policy for a reader's consumer, configured as
{Pulsar.Reader.Callback, :report_permits, [stream_pid, reader_ref]}.
Callback implementation for Pulsar.Consumer.Callback.terminate/2.
Functions
Callback implementation for Pulsar.Consumer.Callback.became_active/1.
Callback implementation for Pulsar.Consumer.Callback.became_passive/1.
Callback implementation for Pulsar.Consumer.Callback.handle_call/3.
Callback implementation for Pulsar.Consumer.Callback.handle_cast/2.
Callback implementation for Pulsar.Consumer.Callback.handle_info/2.
Callback implementation for Pulsar.Consumer.Callback.handle_invalid_message/2.
Flow policy for a reader's consumer, configured as
{Pulsar.Reader.Callback, :report_permits, [stream_pid, reader_ref]}.
Reports rather than grants: the stream process refills as it consumes, which is what keeps the broker from sending further ahead than the stream has read.
Callback implementation for Pulsar.Consumer.Callback.terminate/2.