Pulsar.Reader.Callback (Pulsar v2.8.13)

Copy Markdown View Source

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.

Summary

Functions

handle_call(request, from, state)

Callback implementation for Pulsar.Consumer.Callback.handle_call/3.

handle_cast(request, state)

Callback implementation for Pulsar.Consumer.Callback.handle_cast/2.

handle_info(message, state)

Callback implementation for Pulsar.Consumer.Callback.handle_info/2.

terminate(reason, state)

Callback implementation for Pulsar.Consumer.Callback.terminate/2.

Functions

handle_call(request, from, state)

Callback implementation for Pulsar.Consumer.Callback.handle_call/3.

handle_cast(request, state)

Callback implementation for Pulsar.Consumer.Callback.handle_cast/2.

handle_info(message, state)

Callback implementation for Pulsar.Consumer.Callback.handle_info/2.

terminate(reason, state)

Callback implementation for Pulsar.Consumer.Callback.terminate/2.