forked from prooph/event-store
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* require php 7.4 * add missing nullables * update copyright * use closure instead of callable
- Loading branch information
Showing
148 changed files
with
570 additions
and
792 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
@@ -15,16 +15,12 @@ | |
|
||
class AllEventsSlice | ||
{ | ||
/** @var ReadDirection */ | ||
private $readDirection; | ||
/** @var Position */ | ||
private $fromPosition; | ||
/** @var Position */ | ||
private $nextPosition; | ||
private ReadDirection $readDirection; | ||
private Position $fromPosition; | ||
private Position $nextPosition; | ||
/** @var ResolvedEvent[] */ | ||
private $events; | ||
/** @var bool */ | ||
private $isEndOfStream; | ||
private array $events; | ||
private bool $isEndOfStream; | ||
|
||
/** | ||
* @internal | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
@@ -17,10 +17,8 @@ | |
|
||
class ClientAuthenticationFailedEventArgs implements EventArgs | ||
{ | ||
/** @var EventStoreConnection */ | ||
private $connection; | ||
/** @var string */ | ||
private $reason; | ||
private EventStoreConnection $connection; | ||
private string $reason; | ||
|
||
public function __construct(EventStoreConnection $connection, string $reason) | ||
{ | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
@@ -17,10 +17,8 @@ | |
|
||
class ClientClosedEventArgs implements EventArgs | ||
{ | ||
/** @var EventStoreConnection */ | ||
private $connection; | ||
/** @var string */ | ||
private $reason; | ||
private EventStoreConnection $connection; | ||
private string $reason; | ||
|
||
public function __construct(EventStoreConnection $connection, string $reason) | ||
{ | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
@@ -18,10 +18,8 @@ | |
|
||
class ClientConnectionEventArgs implements EventArgs | ||
{ | ||
/** @var EventStoreConnection */ | ||
private $connection; | ||
/** @var EndPoint */ | ||
private $remoteEndPoint; | ||
private EventStoreConnection $connection; | ||
private EndPoint $remoteEndPoint; | ||
|
||
public function __construct(EventStoreConnection $connection, EndPoint $remoteEndPoint) | ||
{ | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
@@ -18,10 +18,8 @@ | |
|
||
class ClientErrorEventArgs implements EventArgs | ||
{ | ||
/** @var EventStoreConnection */ | ||
private $connection; | ||
/** @var Throwable */ | ||
private $exception; | ||
private EventStoreConnection $connection; | ||
private Throwable $exception; | ||
|
||
public function __construct(EventStoreConnection $connection, Throwable $exception) | ||
{ | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
@@ -17,8 +17,7 @@ | |
|
||
class ClientReconnectingEventArgs implements EventArgs | ||
{ | ||
/** @var EventStoreConnection */ | ||
private $connection; | ||
private EventStoreConnection $connection; | ||
|
||
public function __construct(EventStoreConnection $connection) | ||
{ | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
@@ -14,6 +14,7 @@ | |
namespace Prooph\EventStore\Async; | ||
|
||
use Amp\Promise; | ||
use Closure; | ||
use Prooph\EventStore\AllEventsSlice; | ||
use Prooph\EventStore\CatchUpSubscriptionSettings; | ||
use Prooph\EventStore\ConditionalWriteResult; | ||
|
@@ -241,17 +242,17 @@ public function connectToPersistentSubscriptionAsync( | |
?UserCredentials $userCredentials = null | ||
): Promise; | ||
|
||
public function onConnected(callable $handler): ListenerHandler; | ||
public function onConnected(Closure $handler): ListenerHandler; | ||
|
||
public function onDisconnected(callable $handler): ListenerHandler; | ||
public function onDisconnected(Closure $handler): ListenerHandler; | ||
|
||
public function onReconnecting(callable $handler): ListenerHandler; | ||
public function onReconnecting(Closure $handler): ListenerHandler; | ||
|
||
public function onClosed(callable $handler): ListenerHandler; | ||
public function onClosed(Closure $handler): ListenerHandler; | ||
|
||
public function onErrorOccurred(callable $handler): ListenerHandler; | ||
public function onErrorOccurred(Closure $handler): ListenerHandler; | ||
|
||
public function onAuthenticationFailed(callable $handler): ListenerHandler; | ||
public function onAuthenticationFailed(Closure $handler): ListenerHandler; | ||
|
||
public function detach(ListenerHandler $handler): void; | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -2,8 +2,8 @@ | |
|
||
/** | ||
* This file is part of prooph/event-store. | ||
* (c) 2014-2019 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2019 Sascha-Oliver Prolic <[email protected]> | ||
* (c) 2014-2020 Alexander Miertsch <[email protected]> | ||
* (c) 2015-2020 Sascha-Oliver Prolic <[email protected]> | ||
* | ||
* For the full copyright and license information, please view the LICENSE | ||
* file that was distributed with this source code. | ||
|
@@ -21,16 +21,11 @@ | |
|
||
class EventStoreTransaction | ||
{ | ||
/** @var int */ | ||
private $transactionId; | ||
/** @var UserCredentials|null */ | ||
private $userCredentials; | ||
/** @var EventStoreTransactionConnection */ | ||
private $connection; | ||
/** @var bool */ | ||
private $isRolledBack; | ||
/** @var bool */ | ||
private $isCommitted; | ||
private int $transactionId; | ||
private ?UserCredentials $userCredentials; | ||
private EventStoreTransactionConnection $connection; | ||
private bool $isRolledBack; | ||
private bool $isCommitted; | ||
|
||
public function __construct( | ||
int $transactionId, | ||
|
Oops, something went wrong.