diff --git a/src/AbstractPool.php b/src/AbstractPool.php index fd70271..fde0bd9 100644 --- a/src/AbstractPool.php +++ b/src/AbstractPool.php @@ -83,9 +83,9 @@ abstract class AbstractPool implements Pool * @param Statement $statement * @param callable $prepare * - * @return PooledStatement + * @return StatementPool */ - abstract protected function createPooledStatement(Pool $pool, Statement $statement, callable $prepare): PooledStatement; + abstract protected function createStatementPool(Pool $pool, Statement $statement, callable $prepare): StatementPool; /** * Creates a Transaction of the appropriate type using the Transaction object returned by the Link object and the @@ -381,7 +381,7 @@ abstract class AbstractPool implements Pool { return call(function () use ($sql) { $statement = yield from $this->prepareStatement($sql); - return $this->createPooledStatement($this, $statement, $this->prepare); + return $this->createStatementPool($this, $statement, $this->prepare); }); } diff --git a/src/PooledStatement.php b/src/StatementPool.php similarity index 98% rename from src/PooledStatement.php rename to src/StatementPool.php index 6f3361a..44e927c 100644 --- a/src/PooledStatement.php +++ b/src/StatementPool.php @@ -6,7 +6,7 @@ use Amp\Loop; use Amp\Promise; use function Amp\call; -abstract class PooledStatement implements Statement +abstract class StatementPool implements Statement { /** @var \Amp\Sql\Pool */ private $pool;