anchor.diff:  	?debugMsg("bing"),
   	{next_state, active, State}.
   
  +%% @private
   active_once({recv, _Timeout}, _From, State) ->
   	{reply, {error, not_passive}, active_once, State}.
   
  +%% @private
   active_once({decoded_frames, [], Buffer}, State) ->
   	State2 = State#state{data_buffer = Buffer},
   	socket_setopts(State, [{active, once}]),
  
positive.code: 	payload
  }).
  
  %% public api
  connect(Url, Opts) ->
  	connect(Url, Opts, infinity).
  
  connect(Url, Opts, Timeout) ->
  	Self = self(),
  	case gen_fsm:start(?MODULE, [Self, Url, Opts, Timeout], []) of
  
negative.code: 	gen_fsm:reply(From, {error, timeout}),
  	{stop, normal, State}.
  
  %% @private
  active({recv, _Timeout}, _From, State) ->
  	{reply, {error, not_passive}, active, State};
  
  