jetstream
jetstream copied to clipboard
Allow handle_message/2 to stop running pull consumer
trafficstars
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.