anchor.diff:      {ok, pid()} | {error, Reason :: term()}.
   start_link(Bucket, Scope, Callback, Opts, LinkedProcesses) ->
       gen_server:start_link(?MODULE, [Bucket, Scope, Callback, Opts, LinkedProcesses], []).
  +
  +%%--------------------------------------------------------------------
  +%% @doc
  +%% Asynchronously stops CouchBase changes stream.
  +%% @end
  +%%--------------------------------------------------------------------
  +-spec stop_async(pid()) -> ok.
  +stop_async(StreamPid) ->
  +    gen_server:cast(StreamPid, ?STOP).
   
   %%%===================================================================
   %%% gen_server callbacks
  
positive.code: 
  -type state() :: #state{}.
  
  %%%===================================================================
  %%% API
  %%%===================================================================
  
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,
  