Send response data through pipelines

Author: ivan770

composer.json

@@ -8,7 +8,8 @@
         "illuminate/support": "^5.8"
     },
     "suggest": {
-        "illuminate/database": "Allows to send request with data from model"
+        "illuminate/database": "Allows to send request with data from model",
+        "illuminate/pipeline": "Allows to send response data through pipelines"
     },
     "autoload": {
         "psr-4": {

src/Exceptions/PipelineNotAvailable.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace Ivan770\HttpClient\Exceptions;
+
+use Exception;
+
+class PipelineNotAvailable extends Exception
+{
+    public function __construct($message, $code = 0, Exception $previous = null) {
+        parent::__construct($message, $code, $previous);
+    }
+
+    public function __toString() {
+        return __CLASS__ . ": [{$this->code}]: {$this->message}\n";
+    }
+
+}

src/Response.php

@@ -2,7 +2,9 @@
 
 namespace Ivan770\HttpClient;
 
+use Ivan770\HttpClient\Exceptions\PipelineNotAvailable;
 use Symfony\Component\HttpClient\Exception\JsonException;
+use Illuminate\Pipeline\Pipeline;
 
 /**
  * @method int getStatusCode() Get response status code
@@ -14,11 +16,30 @@ class Response
 {
     protected $baseResponse;
 
+    protected $pipeline;
+
     public function __construct($baseResponse)
     {
         $this->baseResponse = $baseResponse;
     }
 
+    protected function pipelineAvailable()
+    {
+        //TODO: Remove pipeline vendor lock.
+        if (class_exists(Pipeline::class)) {
+            return true;
+        }
+        throw new PipelineNotAvailable("Pipeline class cannot be found");
+    }
+
+    protected function getPipeline()
+    {
+        if ($this->pipelineAvailable() && is_null($this->pipeline)) {
+            $this->pipeline = new Pipeline();
+        }
+        return $this->pipeline;
+    }
+
     /**
      * Create collection from response
      *
@@ -44,6 +65,26 @@ public function getContent($throw = true)
         }
     }
 
+    /**
+     * Pass response content to function
+     *
+     * @param \Closure $function Function to call
+     */
+    public function then($function)
+    {
+        return $function->call($this, $this->getContent());
+    }
+
+    /**
+     * Pass response content to pipeline
+     *
+     * @return Pipeline
+     */
+    public function pipeline()
+    {
+        return $this->getPipeline()->send($this->getContent());
+    }
+
     public function __call($name, $arguments)
     {
         return $this->baseResponse->$name(...$arguments);