public function executeStatement(string $queryString, array $parameters = [])
    {
        return Observable::defer(function() use ($queryString, $parameters) {
            $conn = $this->getLeastBusyConnection();

            return $conn->executeStatement($queryString, $parameters);
        });
    }