src/Qualifiers/CallableQualifier.php
<?php
/*
* This file is part of YaEtl
* (c) Fabrice de Stefanis / https://github.com/fab2s/YaEtl
* This source file is licensed under the MIT license which you will
* find in the LICENSE file or at https://opensource.org/licenses/MIT
*/
namespace fab2s\YaEtl\Qualifiers;
use fab2s\NodalFlow\Flows\InterrupterInterface;
use fab2s\NodalFlow\NodalFlowException;
/**
* Class CallableQualifier
*/
class CallableQualifier extends QualifierAbstract
{
/**
* @var callable
*/
protected $qualifier;
/**
* Instantiate a CallableQualifier Node
*
* @param callable $qualifier
*
* @throws NodalFlowException
*/
public function __construct(callable $qualifier)
{
$this->qualifier = $qualifier;
parent::__construct();
}
/**
* Qualifies a record to either keep it, skip it or break the flow at the execution point
* or at any upstream Node
*
* @param mixed $param
*
* @return InterrupterInterface|bool|null `true` to accept the record, eg let the Flow proceed untouched
* `false|null|void` to deny the record, eg trigger a continue on the carrier Flow (not ancestors)
* `InterrupterInterface` to trigger an interrupt with a target (which may be one ancestor)
*/
public function qualify($param)
{
return \call_user_func($this->qualifier, $param);
}
}