anchor.diff:      StreamRef = gun:get(Pid, Url, Headers),
   
       NewState = clean_state(),
  -    {next_state, wait_response, NewState#{pid := Pid,
  -                                          stream := StreamRef,
  -                                          from := From}}.
  +    {
  +      next_state,
  +      wait_response,
  +      NewState#{pid := Pid, stream := StreamRef, from := From}
  +    }.
   
   -spec wait_response(term(), term()) -> term().
   wait_response({'DOWN', _, _, _, Reason}, _State) ->
  
positive.code: receive_chunk({gun_error, _Pid, _StreamRef, _Reason}, State) ->
      {next_state, at_rest, State}.
  
  %% internal
  clean_state() ->
      #{pid => undefined,
        stream => undefined,
  
negative.code: 
  -spec get(pid(), string(), headers(), options()) -> response().
  get(Pid, Url, HeadersMap, Options) ->
      Headers = basic_auth_header(Options, maps:to_list(HeadersMap)),
  
      HandleEvent = maps_get(handle_event, Options, undefined),
      Async = maps_get(async, Options, undefined),
  