anchor.diff:      {noreply, NewState :: state()} |
       {noreply, NewState :: state(), timeout() | hibernate} |
       {stop, Reason :: term(), NewState :: state()}.
  +handle_cast(?STOP, #state{callback = Callback} = State) ->
  +    Callback({ok, stream_stopped}),
  +    {stop, normal, State};
   handle_cast(Request, #state{} = State) ->
       ?log_bad_request(Request),
       {noreply, State}.
  
positive.code:     {ok, pid()} | {error, Reason :: term()}.
  start_link(Bucket, Scope, Callback, Opts, LinkedProcesses) ->
      gen_server:start_link(?MODULE, [Bucket, Scope, Callback, Opts, LinkedProcesses], []).
  
  %%%===================================================================
  %%% gen_server callbacks
  
negative.code: -include_lib("ctool/include/logging.hrl").
  
  %% API
  -export([start_link/5, stop_async/1]).
  
  %% gen_server callbacks
  -export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2,
  