Merge 340e437 into d200388

prooph · Dec 8, 2018 · 875f68d · 875f68d
2 parents d200388 + 340e437
commit 875f68d
Show file tree

Hide file tree

Showing 89 changed files with 673 additions and 2,612 deletions.
diff --git a/examples/demo-async-cluster.php → examples/demo-cluster.php b/examples/demo-async-cluster.php → examples/demo-cluster.php
@@ -31,7 +31,7 @@
         new EndPoint('localhost', 2133),
     ]);
 
-    $connection = EventStoreAsyncConnectionFactory::createFromSettings(
+    $connection = EventStoreConnectionFactory::createFromSettings(
         $builder->build(),
         'cluster-connection'
     );

diff --git a/examples/demo-async-dns-cluster.php → examples/demo-dns-cluster.php b/examples/demo-async-dns-cluster.php → examples/demo-dns-cluster.php
@@ -29,7 +29,7 @@
         ->setClusterGossipPort(2113)
         ->build();
 
-    $connection = EventStoreAsyncConnectionFactory::createFromSettings(
+    $connection = EventStoreConnectionFactory::createFromSettings(
         $settings,
         'dns-cluster-connection'
     );

diff --git a/examples/demo-persistent-subscription-with-dns-cluster.php b/examples/demo-persistent-subscription-with-dns-cluster.php
@@ -31,7 +31,7 @@
  */
 
 Loop::run(function () {
-    $connection = EventStoreAsyncConnectionFactory::createFromConnectionString(
+    $connection = EventStoreConnectionFactory::createFromConnectionString(
         'Connect To=discover://127.0.0.1:2113',
         null,
         'dns-cluster-connection'

diff --git a/examples/demo-persistent-subscription.php b/examples/demo-persistent-subscription.php
@@ -25,7 +25,7 @@
 require __DIR__ . '/../vendor/autoload.php';
 
 Loop::run(function () {
-    $connection = EventStoreAsyncConnectionFactory::createFromEndPoint(
+    $connection = EventStoreConnectionFactory::createFromEndPoint(
         new EndPoint('eventstore', 1113)
     );
 

diff --git a/examples/demo-async-with-logger.php → examples/demo-read-with-logger.php b/examples/demo-async-with-logger.php → examples/demo-read-with-logger.php
@@ -22,7 +22,7 @@
     $builder->enableVerboseLogging();
     $builder->useConsoleLogger();
 
-    $connection = EventStoreAsyncConnectionFactory::createFromEndPoint(
+    $connection = EventStoreConnectionFactory::createFromEndPoint(
         new EndPoint('eventstore', 1113),
         $builder->build()
     );

diff --git a/examples/demo-async.php → examples/demo-read.php b/examples/demo-async.php → examples/demo-read.php
@@ -18,7 +18,7 @@
 require __DIR__ . '/../vendor/autoload.php';
 
 Loop::run(function () {
-    $connection = EventStoreAsyncConnectionFactory::createFromEndPoint(
+    $connection = EventStoreConnectionFactory::createFromEndPoint(
         new EndPoint('eventstore', 1113)
     );
 

diff --git a/examples/demo-subscribe-to-all-from.php b/examples/demo-subscribe-to-all-from.php
@@ -23,7 +23,7 @@
 require __DIR__ . '/../vendor/autoload.php';
 
 Loop::run(function () {
-    $connection = EventStoreAsyncConnectionFactory::createFromEndPoint(
+    $connection = EventStoreConnectionFactory::createFromEndPoint(
         new EndPoint('eventstore', 1113)
     );
 

diff --git a/examples/demo-subscribe-to-all.php b/examples/demo-subscribe-to-all.php
@@ -23,7 +23,7 @@
 require __DIR__ . '/../vendor/autoload.php';
 
 Loop::run(function () {
-    $connection = EventStoreAsyncConnectionFactory::createFromEndPoint(
+    $connection = EventStoreConnectionFactory::createFromEndPoint(
         new EndPoint('eventstore', 1113)
     );
 

diff --git a/examples/demo-subscribe-to-stream-from-with-logger.php b/examples/demo-subscribe-to-stream-from-with-logger.php
@@ -27,7 +27,7 @@
     $builder->enableVerboseLogging();
     $builder->useConsoleLogger();
 
-    $connection = EventStoreAsyncConnectionFactory::createFromEndPoint(
+    $connection = EventStoreConnectionFactory::createFromEndPoint(
         new EndPoint('eventstore', 1113),
         $builder->build()
     );

diff --git a/examples/demo-subscribe-to-stream-from.php b/examples/demo-subscribe-to-stream-from.php
@@ -23,7 +23,7 @@
 require __DIR__ . '/../vendor/autoload.php';
 
 Loop::run(function () {
-    $connection = EventStoreAsyncConnectionFactory::createFromEndPoint(
+    $connection = EventStoreConnectionFactory::createFromEndPoint(
         new EndPoint('eventstore', 1113)
     );
 

diff --git a/examples/demo-subscribe-to-stream.php b/examples/demo-subscribe-to-stream.php
@@ -23,7 +23,7 @@
 require __DIR__ . '/../vendor/autoload.php';
 
 Loop::run(function () {
-    $connection = EventStoreAsyncConnectionFactory::createFromEndPoint(
+    $connection = EventStoreConnectionFactory::createFromEndPoint(
         new EndPoint('eventstore', 1113)
     );
 

diff --git a/examples/demo-sync.php b/examples/demo-sync.php
diff --git a/src/ClientAuthenticationFailedEventArgs.php b/src/ClientAuthenticationFailedEventArgs.php
@@ -15,18 +15,18 @@
 
 class ClientAuthenticationFailedEventArgs implements EventArgs
 {
-    /** @var EventStoreAsyncConnection */
+    /** @var EventStoreConnection */
     private $connection;
     /** @var string */
     private $reason;
 
-    public function __construct(EventStoreAsyncConnection $connection, string $reason)
+    public function __construct(EventStoreConnection $connection, string $reason)
     {
         $this->connection = $connection;
         $this->reason = $reason;
     }
 
-    public function connection(): EventStoreAsyncConnection
+    public function connection(): EventStoreConnection
     {
         return $this->connection;
     }

diff --git a/src/ClientClosedEventArgs.php b/src/ClientClosedEventArgs.php
@@ -15,18 +15,18 @@
 
 class ClientClosedEventArgs implements EventArgs
 {
-    /** @var EventStoreAsyncConnection */
+    /** @var EventStoreConnection */
     private $connection;
     /** @var string */
     private $reason;
 
-    public function __construct(EventStoreAsyncConnection $connection, string $reason)
+    public function __construct(EventStoreConnection $connection, string $reason)
     {
         $this->connection = $connection;
         $this->reason = $reason;
     }
 
-    public function connection(): EventStoreAsyncConnection
+    public function connection(): EventStoreConnection
     {
         return $this->connection;
     }

diff --git a/src/ClientConnectionEventArgs.php b/src/ClientConnectionEventArgs.php
@@ -15,18 +15,18 @@
 
 class ClientConnectionEventArgs implements EventArgs
 {
-    /** @var EventStoreAsyncConnection */
+    /** @var EventStoreConnection */
     private $connection;
     /** @var EndPoint */
     private $remoteEndPoint;
 
-    public function __construct(EventStoreAsyncConnection $connection, EndPoint $remoteEndPoint)
+    public function __construct(EventStoreConnection $connection, EndPoint $remoteEndPoint)
     {
         $this->connection = $connection;
         $this->remoteEndPoint = $remoteEndPoint;
     }
 
-    public function connection(): EventStoreAsyncConnection
+    public function connection(): EventStoreConnection
     {
         return $this->connection;
     }

diff --git a/src/ClientErrorEventArgs.php b/src/ClientErrorEventArgs.php
@@ -17,18 +17,18 @@
 
 class ClientErrorEventArgs implements EventArgs
 {
-    /** @var EventStoreAsyncConnection */
+    /** @var EventStoreConnection */
     private $connection;
     /** @var Throwable */
     private $exception;
 
-    public function __construct(EventStoreAsyncConnection $connection, Throwable $exception)
+    public function __construct(EventStoreConnection $connection, Throwable $exception)
     {
         $this->connection = $connection;
         $this->exception = $exception;
     }
 
-    public function connection(): EventStoreAsyncConnection
+    public function connection(): EventStoreConnection
     {
         return $this->connection;
     }

diff --git a/src/ClientOperations/StartAsyncTransactionOperation.php b/src/ClientOperations/StartAsyncTransactionOperation.php