Merge 96b8381 into eb70613

src/AsyncCatchUpSubscriptionDropped.php → src/Async/CatchUpSubscriptionDropped.php

@@ -11,14 +11,15 @@
 
 declare(strict_types=1);
 
-namespace Prooph\EventStore;
+namespace Prooph\EventStore\Async;
 
+use Prooph\EventStore\SubscriptionDropReason;
 use Throwable;
 
-interface AsyncCatchUpSubscriptionDropped
+interface CatchUpSubscriptionDropped
 {
     public function __invoke(
-        AsyncEventStoreCatchUpSubscription $subscription,
+        EventStoreCatchUpSubscription $subscription,
         SubscriptionDropReason $reason,
         ?Throwable $exception = null
     ): void;

src/Async/ClientAuthenticationFailedEventArgs.php

@@ -0,0 +1,40 @@
+<?php
+
+/**
+ * This file is part of prooph/event-store.
+ * (c) 2014-2019 prooph software GmbH <contact@prooph.de>
+ * (c) 2015-2019 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Prooph\EventStore\Async;
+
+use Prooph\EventStore\EventArgs;
+
+class ClientAuthenticationFailedEventArgs implements EventArgs
+{
+    /** @var EventStoreConnection */
+    private $connection;
+    /** @var string */
+    private $reason;
+
+    public function __construct(EventStoreConnection $connection, string $reason)
+    {
+        $this->connection = $connection;
+        $this->reason = $reason;
+    }
+
+    public function connection(): EventStoreConnection
+    {
+        return $this->connection;
+    }
+
+    public function reason(): string
+    {
+        return $this->reason;
+    }
+}

src/Async/ClientClosedEventArgs.php

@@ -0,0 +1,40 @@
+<?php
+
+/**
+ * This file is part of prooph/event-store.
+ * (c) 2014-2019 prooph software GmbH <contact@prooph.de>
+ * (c) 2015-2019 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Prooph\EventStore\Async;
+
+use Prooph\EventStore\EventArgs;
+
+class ClientClosedEventArgs implements EventArgs
+{
+    /** @var EventStoreConnection */
+    private $connection;
+    /** @var string */
+    private $reason;
+
+    public function __construct(EventStoreConnection $connection, string $reason)
+    {
+        $this->connection = $connection;
+        $this->reason = $reason;
+    }
+
+    public function connection(): EventStoreConnection
+    {
+        return $this->connection;
+    }
+
+    public function reason(): string
+    {
+        return $this->reason;
+    }
+}

src/Async/ClientConnectionEventArgs.php

@@ -0,0 +1,41 @@
+<?php
+
+/**
+ * This file is part of prooph/event-store.
+ * (c) 2014-2019 prooph software GmbH <contact@prooph.de>
+ * (c) 2015-2019 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Prooph\EventStore\Async;
+
+use Prooph\EventStore\EndPoint;
+use Prooph\EventStore\EventArgs;
+
+class ClientConnectionEventArgs implements EventArgs
+{
+    /** @var EventStoreConnection */
+    private $connection;
+    /** @var EndPoint */
+    private $remoteEndPoint;
+
+    public function __construct(EventStoreConnection $connection, EndPoint $remoteEndPoint)
+    {
+        $this->connection = $connection;
+        $this->remoteEndPoint = $remoteEndPoint;
+    }
+
+    public function connection(): EventStoreConnection
+    {
+        return $this->connection;
+    }
+
+    public function remoteEndPoint(): EndPoint
+    {
+        return $this->remoteEndPoint;
+    }
+}

src/Async/ClientErrorEventArgs.php

@@ -0,0 +1,41 @@
+<?php
+
+/**
+ * This file is part of prooph/event-store.
+ * (c) 2014-2019 prooph software GmbH <contact@prooph.de>
+ * (c) 2015-2019 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Prooph\EventStore\Async;
+
+use Prooph\EventStore\EventArgs;
+use Throwable;
+
+class ClientErrorEventArgs implements EventArgs
+{
+    /** @var EventStoreConnection */
+    private $connection;
+    /** @var Throwable */
+    private $exception;
+
+    public function __construct(EventStoreConnection $connection, Throwable $exception)
+    {
+        $this->connection = $connection;
+        $this->exception = $exception;
+    }
+
+    public function connection(): EventStoreConnection
+    {
+        return $this->connection;
+    }
+
+    public function exception(): Throwable
+    {
+        return $this->exception;
+    }
+}

src/Async/ClientReconnectingEventArgs.php

@@ -0,0 +1,32 @@
+<?php
+
+/**
+ * This file is part of prooph/event-store.
+ * (c) 2014-2019 prooph software GmbH <contact@prooph.de>
+ * (c) 2015-2019 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Prooph\EventStore\Async;
+
+use Prooph\EventStore\EventArgs;
+
+class ClientReconnectingEventArgs implements EventArgs
+{
+    /** @var EventStoreConnection */
+    private $connection;
+
+    public function __construct(EventStoreConnection $connection)
+    {
+        $this->connection = $connection;
+    }
+
+    public function connection(): EventStoreConnection
+    {
+        return $this->connection;
+    }
+}

src/EventAppearedOnAsyncCatchupSubscription.php → src/Async/EventAppearedOnCatchupSubscription.php

@@ -11,14 +11,15 @@
 
 declare(strict_types=1);
 
-namespace Prooph\EventStore;
+namespace Prooph\EventStore\Async;
 
 use Amp\Promise;
+use Prooph\EventStore\ResolvedEvent;
 
-interface EventAppearedOnAsyncCatchupSubscription
+interface EventAppearedOnCatchupSubscription
 {
     public function __invoke(
-        AsyncEventStoreCatchUpSubscription $subscription,
+        EventStoreCatchUpSubscription $subscription,
         ResolvedEvent $resolvedEvent
     ): Promise;
 }

src/EventAppearedOnAsyncPersistentSubscription.php → src/Async/EventAppearedOnPersistentSubscription.php

@@ -11,14 +11,15 @@
 
 declare(strict_types=1);
 
-namespace Prooph\EventStore;
+namespace Prooph\EventStore\Async;
 
 use Amp\Promise;
+use Prooph\EventStore\ResolvedEvent;
 
-interface EventAppearedOnAsyncPersistentSubscription
+interface EventAppearedOnPersistentSubscription
 {
     public function __invoke(
-        AsyncEventStorePersistentSubscription $subscription,
+        EventStorePersistentSubscription $subscription,
         ResolvedEvent $resolvedEvent,
         ?int $retryCount = null
     ): Promise;

src/EventAppearedOnAsyncSubscription.php → src/Async/EventAppearedOnSubscription.php

@@ -11,11 +11,13 @@
 
 declare(strict_types=1);
 
-namespace Prooph\EventStore;
+namespace Prooph\EventStore\Async;
 
 use Amp\Promise;
+use Prooph\EventStore\EventStoreSubscription;
+use Prooph\EventStore\ResolvedEvent;
 
-interface EventAppearedOnAsyncSubscription
+interface EventAppearedOnSubscription
 {
     public function __invoke(
         EventStoreSubscription $subscription,

src/AsyncEventStoreAllCatchUpSubscription.php → src/Async/EventStoreAllCatchUpSubscription.php

@@ -11,9 +11,12 @@
 
 declare(strict_types=1);
 
-namespace Prooph\EventStore;
+namespace Prooph\EventStore\Async;
 
-interface AsyncEventStoreAllCatchUpSubscription extends AsyncEventStoreCatchUpSubscription
+use Prooph\EventStore\EventStoreCatchUpSubscription;
+use Prooph\EventStore\Position;
+
+interface EventStoreAllCatchUpSubscription extends EventStoreCatchUpSubscription
 {
     public function lastProcessedPosition(): Position;
 }

src/AsyncEventStoreCatchUpSubscription.php → src/Async/EventStoreCatchUpSubscription.php

@@ -11,12 +11,13 @@
 
 declare(strict_types=1);
 
-namespace Prooph\EventStore;
+namespace Prooph\EventStore\Async;
 
 use Amp\Promise;
+use Prooph\EventStore\SubscriptionDropReason;
 use Throwable;
 
-interface AsyncEventStoreCatchUpSubscription
+interface EventStoreCatchUpSubscription
 {
     public function isSubscribedToAll(): bool;