Как в 4.1 формировать свечки из тиков в реал тайме?

public abstract class MyCandleSource : Disposable, ICandleSource

public class ParallelMyTraderCandleSource : MyCandleSource
{
private readonly SynchronizedList<Trade> _newTrades = new SynchronizedList<Trade>();

private bool _isInProcess;
private readonly Timer _timer;

/// <summary>
/// Создать <see cref="ParallelTraderCandleSource"/>.
/// </summary>
/// <param name="trader">Торговый шлюз, у которого используется событие <see cref="ITrader.NewTrades"/>.</param>
public ParallelMyCandleSource()
: this(TimeSpan.FromMilliseconds(300))
{ }

/// <summary>
/// Создать <see cref="ParallelTraderCandleSource"/>.
/// </summary>
/// <param name="trader">Торговый шлюз, у которого используется событие <see cref="ITrader.NewTrades"/>.</param>
/// <param name="interval">Интервал отправки новых сделок.</param>
public ParallelMyCandleSource(TimeSpan interval)
: base(int.MaxValue, int.MaxValue)
{

_timer = interval.CreateTimer(OnProcessTrades);
}

/// <summary>
/// Обработчик события <see cref="ITrader.NewTrades"/>.
/// </summary>
/// <param name="trades">Новые сделки.</param>
protected override void OnNewTrades(IEnumerable<Trade> trades)
{
base.OnNewTrades(trades);

_newTrades.AddRange(trades);
}


public override void AddNewTrades(Trade trade)
{
base.AddNewTrades(trade);

_newTrades.Add(trade);
}

private void OnProcessTrades()
{
if (_isInProcess)
return;

_isInProcess = true;

try
{
var newTrades = _newTrades.SyncGet(c =>
{
var retVal = c.ToArray();
c.Clear();
return retVal;
});

if (newTrades.Length > 0)
base.RaiseNewTrades(newTrades);
}
finally
{
_isInProcess = false;
}
}
}