Stream Time Series Data

Stream a time series directly:

Get a time series (e.g. using TimeSeriesFor.Get), and call Stream()/StreamAsync().

IEnumerator<T> Stream(DateTime? from = null, DateTime? to = null, TimeSpan? offset = null);

Task<IAsyncEnumerator<T>> StreamAsync(DateTime? from = null, DateTime? to = null, TimeSpan? offset = null);

Stream results of time series queries:

This syntax is the same as the syntax for streaming query results in general, found here.

IEnumerator<TimeSeriesStreamResult<T>> Stream(
    IQueryable<T> query);

IEnumerator<TimeSeriesStreamResult<T>> Stream(
    IQueryable<T> query,
    out StreamQueryStatistics streamQueryStats);

IEnumerator<TimeSeriesStreamResult<T>> Stream(
    IDocumentQuery<T> query);

IEnumerator<TimeSeriesStreamResult<T>> Stream(
    IRawDocumentQuery<T> query);

IEnumerator<TimeSeriesStreamResult<T>> Stream(
    IRawDocumentQuery<T> query,
    out StreamQueryStatistics streamQueryStats);

IEnumerator<TimeSeriesStreamResult<T>> Stream(
    IDocumentQuery<T> query,
    out StreamQueryStatistics streamQueryStats);

Example I

Using TimeSeriesFor:

var timeseries = session.TimeSeriesFor<HeartRate>("user/1-A");
var results = new List<TimeSeriesEntry>();

using (var TSstream = timeseries.Stream())
{
    while (TSstream.MoveNext())
    {
        results.Add(TSstream.Current);
    }
}

var timeseries = session.TimeSeriesFor<HeartRate>("user/1-A");
var results = new List<TimeSeriesEntry>();
var TSstream = await timeseries.StreamAsync();

await using (TSstream)
{
    while (await TSstream.MoveNextAsync())
    {
        results.Add(TSstream.Current);
    }
}

Example II

Using a RawQuery:

var query = session.Advanced.RawQuery<TimeSeriesRawResult>(@"
    from Users
    select timeseries (
        from HeartRate
    )");

var results = new List<TimeSeriesEntry>();

using (var docStream = session.Advanced.Stream(query))
{
    while (docStream.MoveNext())
    {
        var document = docStream.Current.Result;
        var timeseries = document.Stream;
        while (timeseries.MoveNext())
        {
            results.Add(timeseries.Current);
        }
    }
}

var query = session.Advanced.AsyncRawQuery<TimeSeriesRawResult>(@"
    from Users
    select timeseries (
        from HeartRate
    )");

var results = new List<TimeSeriesEntry>();

await using (var docStream = await session.Advanced.StreamAsync(query))
{
    while (await docStream.MoveNextAsync())
    {
        var document = docStream.Current.Result;
        var timeseries = document.StreamAsync;
        while (await timeseries.MoveNextAsync())
        {
            results.Add(timeseries.Current);
        }
    }
}