update tests

src/Kernel.php

@@ -92,7 +92,7 @@ function buildCommandDispatcher(callable $eventStoreFactory, callable $producerF
             return persistEvents($aggregateResult, $eventStoreFactory, $definition, $definition->extractAggregateId($message));
         };
 
-        $publishEvents = function (AggregateResult $aggregateResult) use ($producerFactory): array {
+        $publishEvents = function (AggregateResult $aggregateResult) use ($producerFactory): AggregateResult {
             return publishEvents($aggregateResult, $producerFactory);
         };
 
@@ -153,7 +153,6 @@ function loadEvents(
     return new ArrayIterator();
 }
 
-
 const persistEvents = 'Prooph\Micro\Kernel\persistEvents';
 
 function persistEvents(AggregateResult $aggregateResult, callable $eventStoreFactory, AggregateDefiniton $definition, string $aggregateId): AggregateResult

tests/KernelTest.php

@@ -20,7 +20,6 @@
 use Prooph\EventStore\StreamName;
 use Prooph\Micro\AggregateDefiniton;
 use Prooph\Micro\AggregateResult;
-use Prooph\Micro\Failure;
 use Prooph\Micro\Kernel as f;
 use ProophTest\Micro\TestAsset\TestAggregateDefinition;
 use Prophecy\Argument;
@@ -67,7 +66,7 @@ public function it_builds_command_dispatcher_and_dispatches(): void
 
         $result = $dispatch($command->reveal());
 
-        $this->assertEquals(['some' => 'state'], $result());
+        $this->assertEquals(['some' => 'state'], $result);
     }
 
     /**
@@ -109,8 +108,8 @@ public function it_builds_command_dispatcher_and_dispatches_but_breaks_when_hand
 
         $result = $dispatch($command->reveal());
 
-        $this->assertInstanceOf(Failure::class, $result);
-        $this->assertEquals('Invalid aggregate result returned', $result());
+        $this->assertInstanceOf(\Exception::class, $result);
+        $this->assertEquals('Invalid aggregate result returned', $result->getMessage());
     }
 
     /**
@@ -261,7 +260,7 @@ public function it_publishes_events(): void
 
         $result = f\publishEvents($aggregateResult, $factory);
 
-        $this->assertEquals(['foo' => 'bar'], $result);
+        $this->assertSame($aggregateResult, $result);
     }
 
     /**
@@ -329,4 +328,27 @@ public function it_throws_exception_when_no_definition_found(): void
 
         f\getAggregateDefinition($message->reveal(), $commandMap);
     }
+
+    /**
+     * @test
+     */
+    public function it_pipes(): void
+    {
+        $result = f\pipleline('strtolower', 'ucfirst')('aBC');
+
+        $this->assertEquals('Abc', $result);
+    }
+
+    /**
+     * @test
+     */
+    public function it_handles_exceptions(): void
+    {
+        $result = f\pipleline(function () {
+            throw new \Exception('Exception there!');
+        }, 'ucfirst')('aBC');
+
+        $this->assertInstanceOf(\Exception::class, $result);
+        $this->assertEquals('Exception there!', $result->getMessage());
+    }
 }