anchor.diff:  
   -define(CONTENT_TYPE, <<"application/logplex-1">>).
   -define(HTTP_VERSION, {1,1}).
  +-define(RECONNECT_MSG, reconnect).
   
   %% ------------------------------------------------------------------
   %% API Function Exports
  
positive.code: %% @private
  disconnected({logplex_drain_buffer, Buf, new_data},
               State = #state{buf = Buf}) ->
      try_connect(State);
  disconnected(timeout, State = #state{buf = Buf,
                                       out_q = Q}) ->
      case queue:is_empty(Q) of
          true ->
              logplex_drain_buffer:notify(Buf),
              {next_state, disconnected, State};
          false ->
              try_connect(State)
      end;
  disconnected(Msg, State) ->
      ?WARN("drain_id=~p channel_id=~p dest=~s err=unexpected_info "
            "data=~p state=disconnected",
  
negative.code: %% @private
  http_fail(State = #state{}) ->
      %% XXX - forcibly shutdown client if necessary.
      {next_state, disconnected,
       set_reconnect_timer(State#state{client=undefined})}.
  
  %% @private
  ready_to_send(State = #state{buf = Buf, drain_tok=Token,
  