Indicators

// Create an indicator
private Delay _delay;
_delay = new Delay(20);

// Create a candlestick pattern
private TwoCrows _twoCrows;
_twoCrows = new TwoCrows();

# Create an indicator
self.delay = Delay(20)

# Create a candlestick pattern
self.two_crows = TwoCrows()

// Name an indicator
_delay = new Delay("AAPL Past Price", 20);
Log(_delay.Name);

// Name a candlestick pattern
_twoCrows = new TwoCrows("Two Crows Pattern");
Log(_twoCrows.Name);

# Name an indicator
self.delay = Delay("AAPL Past Price", 20)
self.log(self.delay.name)

# Name a candlestick pattern
self.two_crows = TwoCrows("Two Crows Pattern")
self.log(self.two_crows.name)

def initialize(self) -> None:
    self._symbol = self.add_equity("SPY", Resolution.DAILY).symbol

    self._rsi = RelativeStrengthIndex(10, MovingAverageType.SIMPLE)
    self.ad = AccumulationDistribution()

    self.consolidator = TradeBarConsolidator(timedelta(3))   # 10 x 3 daily trade bars to warm up the RSI.
    self.consolidator = QuoteBarConsolidator(timedelta(3))   # 10 x 3 daily quote bars to warm up the RSI.
    self.consolidator = RenkoBarConsolidator(1)     # Renko consolidator that emits a bar when the price moves $1
    # Update the AD indicator with the consolidated bar
    self.consolidator.data_consolidated += self.on_data_consolidated
    self.subscription_manager.add_consolidator(self._symbol, self.consolidator)

def on_data_consolidated(self, sender, bar):
    self.ad.update(bar)

def on_data(self, slice: Slice) -> None:
    # Update the RSI indicator value with the new input close price every day
    if slice.bars.contains_key(self._symbol):
        bar = slice.bars[self._symbol]
        self.rsi.update(bar.end_time, bar.close)

private Symbol _symbol;
private RelativeStrengthIndex _rsi;
private AccumulationDistribution _ad;

public override void Initialize()
{
    _symbol = AddEquity("SPY", Resolution.Daily).Symbol;
    
    _rsi = new RelativeStrengthIndex(10, MovingAverageType.Simple);
    _ad = new AccumulationDistribution();

    var consolidator = new TradeBarConsolidator(TimeSpan.FromDays(3));   // 10 x 3 daily trade bars to warm up the RSI.
    consolidator = new QuoteBarConsolidator(TimeSpan.FromDays(3));       // 10 x 3 daily quote bars to warm up the RSI.
    consolidator = new RenkoBarConsolidator(1);     // Renko consolidator that emits a bar when the price moves $1
    //Update the AD indicator with the consolidated bar
    consolidator.DataConsolidated += (_, bar) => _ad.Update(bar);
    SubscriptionManager.AddConsolidator(_symbol, consolidator);
}

public override void OnData(Slice slice)
{
    // Update the RSI indicator value with the new input close price every day
    if (slice.Bars.ContainsKey(_symbol))
    {
        var bar = slice.Bars[_symbol];
        _rsi.Update(bar.EndTime, bar.Close);
    }
}

# Create a security subscription 
self._symbol = self.add_equity("SPY", Resolution.MINUTE).symbol

# Create a manual indicator
self.indicator = RelativeStrengthIndex(10, MovingAverageType.SIMPLE)

# Create a consolidator
consolidator = TradeBarConsolidator(3)   # 10 x 3 min trade bars to warm up the RSI.
consolidator = QuoteBarConsolidator(4)   # 10 x 4 min quote bars to warm up the RSI
consolidator = RenkoConsolidator(1)      # Renko consolidator that emits a bar when the price moves $1

# Register the indicator to update with the consolidated data
self.register_indicator(self._symbol, self.indicator, consolidator)

// Create a security subscription 
_symbol = AddEquity("SPY", Resolution.Hour);

// Create a manual indicator
_indicator = new RelativeStrengthIndex(10, MovingAverageType.Simple);

// Create a consolidator
var consolidator = new TradeBarConsolidator(3);   // 10 x 3 min trade bars to warm up the RSI.
consolidator = new QuoteBarConsolidator(4);       // 10 x 4 min quote bars to warm up the RSI.
consolidator = new RenkoConsolidator(1);          // Renko consolidator that emits a bar when the price moves $1

// Register the indicator to update with the consolidated data
RegisterIndicator(_symbol, _indicator, consolidator);