Rename PooledStatement to StatementPool
This commit is contained in:
parent
7df38b63fc
commit
53ad3269f7
@ -83,9 +83,9 @@ abstract class AbstractPool implements Pool
|
|||||||
* @param Statement $statement
|
* @param Statement $statement
|
||||||
* @param callable $prepare
|
* @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
|
* 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) {
|
return call(function () use ($sql) {
|
||||||
$statement = yield from $this->prepareStatement($sql);
|
$statement = yield from $this->prepareStatement($sql);
|
||||||
return $this->createPooledStatement($this, $statement, $this->prepare);
|
return $this->createStatementPool($this, $statement, $this->prepare);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -6,7 +6,7 @@ use Amp\Loop;
|
|||||||
use Amp\Promise;
|
use Amp\Promise;
|
||||||
use function Amp\call;
|
use function Amp\call;
|
||||||
|
|
||||||
abstract class PooledStatement implements Statement
|
abstract class StatementPool implements Statement
|
||||||
{
|
{
|
||||||
/** @var \Amp\Sql\Pool */
|
/** @var \Amp\Sql\Pool */
|
||||||
private $pool;
|
private $pool;
|
Loading…
Reference in New Issue
Block a user