G>Обновляльщик Цен -> (Таблица Товаров) -> Принимальщик Решений
G>

// Принимальщик решений
bool bGo = true;

while (bGo)
{
    Отмена_Текущей_Заявки();
    Подача_Новой_Заявки();
    // ...
    Sleep(TimeToSleep);
}

// Обновляльщик цен
void Обновление_Цен()
{
    bool bGo = true;

    while (bGo)
    {
        Получить_Биржевой_Тик();
        Обновить_Таблицу_Товаров();
        Sleep(TimeToSleep);
    }
}

Если пришло А
{
    Взять Б. 
    В зависимости от (А,Б) выполнить действие (тоже if)
}
Если пришло Б
{
    Взять А.
    В зависимости от (А,Б) выполнить действие (тоже if).
}

G>Если пришло А
G>{
G>    Взять Б. 
G>    В зависимости от (А,Б) выполнить действие (тоже if)
G>}
G>Если пришло Б
G>{
G>    Взять А.
G>    В зависимости от (А,Б) выполнить действие (тоже if).
G>}
G>

if (A)
{
    if (B)
    {
        if (!C)
            do1();

        do2();
    }
    else
    {
        if (C)
           do1();
        else
            do3();

        do4();
    }
}
else
{
    if (B)
    {
        if (!C)
            do1();

        do5();
    }
    else
    {
        if (C)
            do1();
        else
            do6();

        do2();
    }
}

if (A && B && !C || A && !B && C || !A && B && !C || !A && !B && C)
    do1();

if (!A && !B && !C)
    do6();

if (A && B || !A && !B)
    do2();

if (A && !B && !C)
    do3();

if (A && !B)
    do4();

if (!A && B)
    do5();

if (B != С)
    do1();

if (!A && !B && !C)
    do6();

if (A == B)
    do2();

if (A && !B && !C)
    do3();

if (A && !B)
    do4();

if (!A && B)
    do5();

        public IObservable<IList<OIValue>> CategoryUpdates(OICategory cat)
        {
            var query = m_connection.QueryUpdateAsync(cat, ...);
            var result = Observable.Create<IList<OIValue>>(
                obsrv =>
                {
                    query.OnCode += (code, q) =>
                        {
                            if (code != 0)
                                obsrv.OnError(new Exception("... error: " + code));
                        };
                    query.OnData += (data, q) =>
                        {
                            obsrv.OnNext(data); 
                        };
                    return () => query.End(); 
                });
            query.Start();
            return result;
        }

            var attachments = new List<IDisposable>()
            {
                Observable.Merge(
                    Suite.SuiteOK(SuiteDetails).Select(x => Tuple.Create(AttentionLevelEnum.OK, x.Item1, x.Item2)),
                    Suite.SuiteWarning(SuiteDetails).Select(x => Tuple.Create(AttentionLevelEnum.Warning, x.Item1, x.Item2)),
                    Suite.SuiteError(SuiteDetails).Select(x => Tuple.Create(AttentionLevelEnum.Error, x.Item1, x.Item2)))
                    .ObserveOn(this)
                    .Subscribe(
                        item => 
                        {
                            ... Update UI State ...
                        }),
            };

            this.HandleDestroyed += (s, evt) => attachments.ForEach(elem => elem.Dispose());