paginate_ohlc

Defined in dccd.transport.paginate

async paginate_ohlc(fetch_page, cap, start_ns, end_ns, span, *, emit_progress=None)

Paginate OHLC bars forward using declared Capability.

Parameters:

fetch_pageasync callable

Must be a closure with symbol and span already bound: fetch_page(start_ns, end_ns, limit) -> list[OHLCBar].

capCapability

Source capability (provides max_per_request and page_direction).

start_ns, end_nsint

Time range in nanoseconds.

spanint

Candle interval in seconds — used to compute the page window.