@@ -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 | { |