/// <summary>
    /// Конкретный метод расширения
    /// </summary>
    /// <returns>
    ```
    protected abstract Task<TrafficSignal> Executing();

    /// <summary>
    ///  Конкретный метод расширения
    /// </summary>
    /// <returns>
    ```
        protected abstract Task<TrafficSignal<TRes>> Executing();
    ```

* BasePassiveActivity<TPara, TRes>, BasePassiveActivity<TPara, TRes,TOut> — пассивные компоненты действий, запускаемые по запросу. Когда поток достигает этого компонента, процесс останавливается, ожидая вызова метода Execute внешним узлом. После вызова поток продолжает движение к следующему узлу (параметр вызова становится новым контекстом). Эти классы наследуются и метод Executing переопределяется для реализации конкретных бизнес-логик.

```csharp
    /// <summary>
    ```
    /// Конкретный метод расширения
    /// ```
    /// <param name="para">Текущий контекст действия</param>
    /// <returns>
    ```
    protected abstract Task<TrafficSignal<TRes>> Executing(TPara para);
    ```

* BasePassiveEffectActivity<TPara, TRes> — пассивный компонент действий с влиянием на контекст, аналогичный активному компоненту действий с влиянием на контекст. Результат метода Executing становится контекстом для следующего узла.

Эти четыре класса действий включают метод Execute, который позволяет запускать действия непосредственно из любого узла. ### 4. BaseMsgSubscriber<TMsg> - 消息订阅者组件 (предоставляет реализацию по умолчанию: MsgSubscriber<TMsg>)

Ранее компонент предоставлял способ **подписки** на данные, источник триггера можно было легко изменить на очередь или базу данных (подробности см. в OSS.DataFlow [https://github.com/KevinWG/OSS.DataFlow]).

### Простой пример сценария

Предположим, что у нас есть сценарий управления запасами, который включает в себя несколько этапов: заявка на поставку, утверждение заявки, покупка и оплата, а также размещение на складе (с одновременным уведомлением заявителя по электронной почте). Каждый этап представляет собой событие-активность, например, заявка может быть определена следующим образом:
```csharp
    public class ApplyActivity : BaseEffectActivity<ApplyContext, long>
    {
        public ApplyActivity()
        {
            PipeCode = "ApplyActivity";
        }
        
        protected override Task<TrafficSignal<long>> Executing(ApplyContext para)
        {
            LogHelper.Info($"发起 [{para.name}] 采购申请");
            return Task.FromResult(new TrafficSignal<long>(100000001L));
        }
    }

    ApplyActivity      - заявка (параметр: ApplyContext)
    AutoAuditActivity  - утверждение (параметр: long)
    PayActivity        - покупка (параметр: PayContext)
    StockActivity      - размещение (параметр: StockContext)
    EmailActivity      - отправка электронного письма (параметр: SendEmailContext)

    public class PayGateway : BaseBranchGateway<PayContext>
    {
        public PayGateway()
        {
            PipeCode = "PayGateway";
        }

        protected override bool FilterBranchCondition(PayContext branchContext, IPipe branch, string prePipeCode)
        {
            LogHelper.Info($"通过{PipeCode}  суждение о том, удовлетворяет ли ветвь {branch.PipeCode} условию разветвления!");
            return base.FilterBranchCondition(branchContext, branch, prePipeCode);
        }
    }

    public class PayEmailConnector : BaseMsgConverter<PayContext, SendEmailContext>
    {
        public PayEmailConnector()
        {
            PipeCode = "PayEmailConnector";
        }
        protected override SendEmailContext Convert(PayContext inContextData)
        {
            // ......
            return new SendEmailContext() { body = $" 您成功支付了订单，总额：{inContextData.money}" };
        }
    }

    [TestClass]
    public class BuyFlowTests
    {
        public readonly ApplyActivity     ApplyActivity = new ApplyActivity();
        public readonly AutoAuditActivity AuditActivity = new AutoAuditActivity();

        public readonly PayActivity PayActivity = new PayActivity();

        public readonly PayGateway PayGateway = new PayGateway();

        public readonly StockConnector StockConnector = new StockConnector();
        public readonly StockActivity  StockActivity  = new StockActivity();

        public readonly PayEmailConnector EmailConnector = new PayEmailConnector();
        public readonly SendEmailActivity EmailActivity  = new SendEmailActivity();



        private EndGateway _endNode = new EndGateway();

        //  Конструктор определяет связь с потоком
        public BuyFlowTests()
        {


            ApplyActivity
            .Append(AuditActivity)

            .Append(PayActivity)
            .Append(PayGateway);

            // Разветвляющий шлюз - ветка отправки электронной почты
            PayGateway
            .Append(EmailConnector)
            .Append(EmailActivity)
            .Append(_endNode);

            // Разветвляющий шлюз — ветка размещения на складе
            PayGateway
            .Append(StockConnector)
            .Append(StockActivity)
            .Append(_endNode);


        }

        [TestMethod]
        public async Task FlowTest()
        {
            await ApplyActivity.Execute(new ApplyContext()
            {
                name = "холодильник"
            });

            // Задержка на одну секунду, имитирующая операцию оплаты
            await Task.Delay(1000);

            await PayActivity.Execute(new PayContext()
            {
                count = 10,
                money = 10000
            });
            await Task.Delay(1000);// Ожидание завершения асинхронного журнала
        }

        [TestMethod]
``` ```
public void RouteTest()
{
    var TestPipeline = new Pipeline<ApplyContext, Empty>("test-flow", ApplyActivity, _endNode);

    var route = TestPipeline.ToRoute();
    Assert.IsTrue(route != null);
}