Provide a SlurpPayload when the Load Aborted Event is triggered.

src/Event/LoadAbortedEvent.php

@@ -7,9 +7,29 @@
 
 namespace MilesAsylum\Slurp\Event;
 
+use MilesAsylum\Slurp\SlurpPayload;
 use Symfony\Component\EventDispatcher\Event;
 
 class LoadAbortedEvent extends Event
 {
+    /**
+     * @var SlurpPayload|null
+     */
+    private $payload;
+
     public const NAME = 'slurp.load.aborted';
+
+    public function __construct(SlurpPayload $payload = null)
+    {
+        $this->payload = $payload;
+    }
+
+    /**
+     * The payload that caused the load to be aborted.
+     * @return SlurpPayload|null
+     */
+    public function getPayload():? SlurpPayload
+    {
+        return $this->payload;
+    }
 }

src/InnerPipeline/LoadStage.php

@@ -41,7 +41,7 @@ public function __invoke(SlurpPayload $payload): SlurpPayload
                 $this->loader->abort();
                 $this->loadAborted = true;
                 $payload->setLoadAborted($this->loadAborted);
-                $this->dispatch(LoadAbortedEvent::NAME, new LoadAbortedEvent());
+                $this->dispatch(LoadAbortedEvent::NAME, new LoadAbortedEvent($payload));
             } else {
                 $this->loader->loadValues($payload->getRecord());
                 $this->dispatch(RecordLoadedEvent::NAME, new RecordLoadedEvent($payload));

tests/Slurp/Event/LoadAbortedEventTest.php

@@ -0,0 +1,30 @@
+<?php
+/**
+ * Author: Courtney Miles
+ * Date: 26/03/19
+ * Time: 5:18 PM
+ */
+
+namespace MilesAsylum\Slurp\Tests\Slurp\Event;
+
+use MilesAsylum\Slurp\Event\LoadAbortedEvent;
+use MilesAsylum\Slurp\SlurpPayload;
+use PHPUnit\Framework\TestCase;
+
+class LoadAbortedEventTest extends TestCase
+{
+    public function testGetPayloadDefaultValue()
+    {
+        $event = new LoadAbortedEvent();
+
+        $this->assertNull($event->getPayload());
+    }
+
+    public function testGetPayload()
+    {
+        $mockPayload = \Mockery::mock(SlurpPayload::class);
+        $event = new LoadAbortedEvent($mockPayload);
+
+        $this->assertSame($mockPayload, $event->getPayload());
+    }
+}

tests/Slurp/InnerPipeline/LoadStageTest.php

@@ -133,14 +133,29 @@ public function testDispatchEventOnLoad()
 
     public function testDispatchLoadAbortedEventOnInvalidRecord()
     {
+        /** @var LoadAbortedEvent $event */
+        $event = null;
         $mockPayload = $this->createMockPayload(['foo'], true);
         $mockDispatcher = \Mockery::mock(EventDispatcherInterface::class);
         $mockDispatcher->shouldReceive('dispatch')
-            ->with(LoadAbortedEvent::NAME, \Mockery::type(LoadAbortedEvent::class))
-            ->once();
+            ->with(
+                LoadAbortedEvent::NAME,
+                \Mockery::on(
+                    function ($arg) use (&$event) {
+                        if (!$arg instanceof LoadAbortedEvent) {
+                            return false;
+                        }
+
+                        $event = $arg;
+
+                        return true;
+                    }
+                )
+            )->once();
         $this->stage->setEventDispatcher($mockDispatcher);
 
         ($this->stage)($mockPayload);
+        $this->assertSame($mockPayload, $event->getPayload());
     }
 
     /**