View Source grisp_updater_sink behaviour (grisp_updater v2.1.1)

Summary

Callbacks

sink_data/3
sink_done/3
sink_error/3

Callbacks

sink_data/3

-callback sink_data(StreamRef :: reference(), Params :: term(), Data :: binary()) ->
                       ok | {abort, Reason :: term()}.

sink_done/3

-callback sink_done(StreamRef :: reference(), Params :: term(), Data :: binary()) -> ok.

sink_error/3

-callback sink_error(StreamRef :: reference(), Params :: term(), Reason :: term()) -> ok.