gistfile1.txt

public IObservable<T> ExecuteQuery<T>(TableQuery<T> query, TableRequestOptions requestOptions = null, OperationContext operationContext = null) where T : ITableEntity, new()
{
    return Observable.Create<T>(
        async (observer, ct) =>
        {
            var tableToken = new TableContinuationToken();
            while (tableToken != null)
            {
                var results = await ExecuteQuerySegmented(query, tableToken, requestOptions, operationContext, ct);
                foreach (var result in results)
                {
                    observer.OnNext(result);
                }

                tableToken = results.ContinuationToken;
            }
        });
}