anchor.diff:  -record(stream, {
        gun_stream,
        event
  +}).
  +-record(sub_stream, {
  +    gun_stream,
  +    sub
   }).
   -type state() :: #state{}.
   
  
positive.code:     {noreply, State#state{state = down}};
  handle_info({gun_response, _ConnPid, StreamRef, fin, _Status, Headers}, State) ->
      lager:info("[~p] No data for ~p, headers are ~p", [State#state.target, StreamRef, Headers]),
      {noreply, remove_stream(StreamRef, State)};
  handle_info({gun_response, _ConnPid, StreamRef, nofin, _Status, Headers}, State) ->
      lager:info("[~p] Got headers for ~p: ~p", [State#state.target, StreamRef, Headers]),
      %NewState = manage_data(Headers, StreamRef, false, State),    
  
negative.code:         [
              {<<"last-event-id">>, integer_to_list(spread_sub:timestamp(Sub))}
          ]),
      add_subscriptions(Subs, add_subs_stream(Stream, Sub, State)).
  
  add_binary_stream(Event, State) ->
      Stream = gun:get(State#state.connpid,
  