| 499 | } |
| 500 | |
| 501 | fn columns_to_rows(columns: &OhlcvColumns) -> Vec<OhlcvRow> { |
| 502 | let mut rows = Vec::with_capacity(columns.timestamps_us.len()); |
| 503 | for i in 0..columns.timestamps_us.len() { |
| 504 | let dt = DateTime::<Utc>::from_timestamp_micros(columns.timestamps_us[i]) |
| 505 | .expect("valid datetime") |
| 506 | .naive_utc(); |
| 507 | rows.push(OhlcvRow { |
| 508 | timestamp: dt, |
| 509 | symbol: columns.symbols[i].clone(), |
| 510 | open: columns.open[i], |
| 511 | high: columns.high[i], |
| 512 | low: columns.low[i], |
| 513 | close: columns.close[i], |
| 514 | volume: columns.volume[i], |
| 515 | adj_close: columns.adj_close[i], |
| 516 | }); |
| 517 | } |
| 518 | rows |
| 519 | } |
| 520 | |
| 521 | fn aligned_columns_to_rows(columns: &AlignedOhlcvColumns) -> Vec<AlignedOhlcvRow> { |
| 522 | let mut rows = Vec::with_capacity(columns.timestamps_us.len()); |