/*
* QUANTCONNECT.COM - Democratizing Finance, Empowering Individuals.
* Lean Algorithmic Trading Engine v2.0. Copyright 2014 QuantConnect Corporation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using QuantConnect.Data;
namespace QuantConnect.Indicators
{
///
/// Represents an indicator that acts on a rolling window of data
///
public abstract class WindowIndicator : IndicatorBase, IIndicatorWarmUpPeriodProvider
where T : IBaseData
{
// a window of data over a certain look back period
private readonly RollingWindow _window;
///
/// Gets the period of this window indicator
///
public int Period => _window.Size;
///
/// Initializes a new instance of the WindowIndicator class
///
/// The name of this indicator
/// The number of data points to hold in the window
protected WindowIndicator(string name, int period)
: base(name)
{
_window = new RollingWindow(period);
}
///
/// Gets a flag indicating when this indicator is ready and fully initialized
///
public override bool IsReady => _window.IsReady;
///
/// Required period, in data points, to the indicator to be ready and fully initialized
///
public virtual int WarmUpPeriod => Period;
///
/// Computes the next value of this indicator from the given state
///
/// The input given to the indicator
/// A new value for this indicator
protected override decimal ComputeNextValue(T input)
{
_window.Add(input);
return ComputeNextValue(_window, input);
}
///
/// Resets this indicator to its initial state
///
public override void Reset()
{
base.Reset();
_window.Reset();
}
///
/// Computes the next value for this indicator from the given state.
///
/// The window of data held in this indicator
/// The input value to this indicator on this time step
/// A new value for this indicator
protected abstract decimal ComputeNextValue(IReadOnlyWindow window, T input);
}
}