Skip to content
This repository was archived by the owner on Nov 20, 2025. It is now read-only.
This repository was archived by the owner on Nov 20, 2025. It is now read-only.

Allow handle_message/2 to stop running pull consumer #28

@mkaput

Description

@mkaput

Allow Jetstream.PullConsumer.handle_message/2 callback return {:stop, reason, new_state} tuple. It should behave exactly the same as it would be returned from GenServer's handle_call/2 or Connection's counterparts.

Metadata

Metadata

Assignees

No one assigned

    Labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions