@@ -244,7 +244,7 @@ |
||
| 244 | 244 | /** |
| 245 | 245 | * @param int $token |
| 246 | 246 | * @param MessageInterface $message |
| 247 | - * @return array |
|
| 247 | + * @return ResponseInterface |
|
| 248 | 248 | * @throws \RuntimeException |
| 249 | 249 | * @throws ConnectionException |
| 250 | 250 | */ |
@@ -7,7 +7,6 @@ |
||
| 7 | 7 | use Symfony\Component\Serializer\SerializerInterface; |
| 8 | 8 | use TBolier\RethinkQL\Connection\Socket\Exception; |
| 9 | 9 | use TBolier\RethinkQL\Connection\Socket\HandshakeInterface; |
| 10 | -use TBolier\RethinkQL\Query\Cursor; |
|
| 11 | 10 | use TBolier\RethinkQL\Query\Expr; |
| 12 | 11 | use TBolier\RethinkQL\Query\Message; |
| 13 | 12 | use TBolier\RethinkQL\Query\MessageInterface; |
@@ -31,6 +31,9 @@ |
||
| 31 | 31 | $this->setBatch($response); |
| 32 | 32 | } |
| 33 | 33 | |
| 34 | + /** |
|
| 35 | + * @param ResponseInterface $response |
|
| 36 | + */ |
|
| 34 | 37 | private function setBatch($response) |
| 35 | 38 | { |
| 36 | 39 | $this->isComplete = $response['t'] === ResponseType::SUCCESS_SEQUENCE; |
@@ -30,11 +30,6 @@ |
||
| 30 | 30 | private $note; |
| 31 | 31 | |
| 32 | 32 | /** |
| 33 | - * @param int $type |
|
| 34 | - * @param array $data |
|
| 35 | - * @param array $backtrace |
|
| 36 | - * @param array|null $profile |
|
| 37 | - * @param array|null $note |
|
| 38 | 33 | */ |
| 39 | 34 | public function __construct(int $t = null, array $r = null, array $b = null, array $p = null, array $n = null) |
| 40 | 35 | { |