Skip to content

Commit

Permalink
✨ Add webhook support
Browse files Browse the repository at this point in the history
  • Loading branch information
Mathieu Ledru committed May 11, 2023
1 parent b446e65 commit 8c986af
Showing 1 changed file with 20 additions and 0 deletions.
20 changes: 20 additions & 0 deletions src/Flow/WebhookFlow.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
<?php

declare(strict_types=1);

namespace Flow\Flow;

use Closure;
use Flow\DriverInterface;
use Flow\IpStrategyInterface;

class WebhookFlow extends FlowDecorator
{
public function __construct(Closure $job, Closure $errorJob = null, ?IpStrategyInterface $ipStrategy = null, ?DriverInterface $driver = null)
{
$U = fn (Closure $f) => $f($f);
$Y = fn (Closure $f) => $U(fn (Closure $x) => $f(fn ($y) => $U($x)($y)));

parent::__construct(new Flow($Y($job), $errorJob, $ipStrategy, $driver));
}
}

0 comments on commit 8c986af

Please sign in to comment.