Skip to content
This repository was archived by the owner on Jun 10, 2022. It is now read-only.

Commit e14311b

Browse files
committed
fixed cs
1 parent 041d9bf commit e14311b

File tree

3 files changed

+13
-13
lines changed

3 files changed

+13
-13
lines changed

src/Consumer/State.php

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -38,17 +38,17 @@ class State
3838

3939
private $callStatus = [];
4040

41-
private $requests = [
42-
self::REQUEST_METADATA => [],
43-
self::REQUEST_GETGROUP => [],
44-
self::REQUEST_JOINGROUP => [],
45-
self::REQUEST_SYNCGROUP => [],
46-
self::REQUEST_HEARTGROUP => [],
47-
self::REQUEST_OFFSET => ['interval' => 2000],
48-
self::REQUEST_FETCH => ['interval' => 100],
49-
self::REQUEST_FETCH_OFFSET => ['interval' => 2000],
50-
self::REQUEST_COMMIT_OFFSET => ['norepeat' => true],
51-
];
41+
private $requests = [
42+
self::REQUEST_METADATA => [],
43+
self::REQUEST_GETGROUP => [],
44+
self::REQUEST_JOINGROUP => [],
45+
self::REQUEST_SYNCGROUP => [],
46+
self::REQUEST_HEARTGROUP => [],
47+
self::REQUEST_OFFSET => ['interval' => 2000],
48+
self::REQUEST_FETCH => ['interval' => 100],
49+
self::REQUEST_FETCH_OFFSET => ['interval' => 2000],
50+
self::REQUEST_COMMIT_OFFSET => ['norepeat' => true],
51+
];
5252

5353
private $loop = null;
5454

src/Producer.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ public function __construct(callable $producer = null)
2626
} else {
2727
$this->process = new \Kafka\Producer\Process($producer);
2828
}
29-
$this->loop = Loop::getInstance();
29+
$this->loop = Loop::getInstance();
3030
}
3131

3232
/**

tests/Base/SocketTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -442,7 +442,7 @@ private function mockStreamSocketClient($host, $port, $config = null, $sasl = nu
442442
$mockMethod = array_merge(['createSocket'], $mockMethod);
443443
}
444444

445-
$socket = $this->getMockBuilder(Socket::class)
445+
$socket = $this->getMockBuilder(Socket::class)
446446
->setMethods($mockMethod)
447447
->setConstructorArgs([$host, $port, $config, $sasl])
448448
->getMock();

0 commit comments

Comments
 (0)