anchor.diff:                  {session_closed, Tag, Result} ->
                       erlcass_log:send(LogPid, ?CASS_LOG_INFO, <<"Session closed with result: ~p">>,[Result])
   
  -            after ?TIMEOUT ->
  +            after ?RESPONSE_TIMEOUT ->
                   erlcass_log:send(LogPid, ?CASS_LOG_ERROR, <<"Session closed timeout">>,[])
               end;
           _ ->
  
positive.code:     erlcass_log:send(State#state.log_pid, ?CASS_LOG_INFO, <<"Prepared statement id: ~p result: ~p">>, [Identifier, Result]),
  
      case Result of
          {ok, StatementRef} ->
              erlcass_prep_utils:set(Identifier, State#state.session, StatementRef),
              gen_server:reply(From, ok);
          _ ->
              gen_server:reply(From, Result)
  
negative.code: 
      async_execute_statement(Stm).
  
  -spec(execute(Identifier :: atom() | binary()) -> {ok, Result :: list()} | ec_error()).
  
  execute(Identifier) ->
      {ok, Tag} = async_execute(Identifier),
      receive_response(Tag).
  
  -spec(execute(Identifier :: atom() | binary(), Params :: list()) -> {ok, Result :: list()} | ec_error()).
  
  execute(Identifier, Params) ->
      execute(Identifier, ?BIND_BY_INDEX, Params).
  
  -spec(execute(Identifier :: atom() | binary(), BindType :: integer(), Params :: list()) -> {ok, Result :: list()} | ec_error()).
  
  execute(Identifier, BindType, Params) ->
      {ok, Tag} = async_execute(Identifier, BindType, Params),
      receive_response(Tag).
  
  -spec(batch_async_execute(BatchType :: integer(), StmList :: list(), Options :: list()) -> {ok, Tag :: reference()} | ec_error()).
  
  batch_async_execute(BatchType, StmList, Options) ->
      gen_server:call(?MODULE, {batch_execute, BatchType, StmList, Options}).
  
  -spec(batch_execute(BatchType :: integer(), StmList :: list(), Options :: list()) -> {ok, Result :: list()} | ec_error()).
  
  batch_execute(BatchType, StmList, Options) ->
      {ok, Tag} = batch_async_execute(BatchType, StmList, Options),
  