fits-io 0.1.0

A pure-Rust FITS file handling library inspired by CFITSIO, focused on safety, clarity, and performance.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use crate::util::ReadSeek;
use futures::stream::BoxStream;
use futures::{Stream, StreamExt, stream};
use std::prelude::rust_2015::{Box, Vec};
use tokio::sync::mpsc::channel;
use tokio_stream::wrappers::ReceiverStream;

pub fn read_bytes_async(
    mut reader: Box<dyn ReadSeek>,
    bytes_to_read: u64,
) -> BoxStream<'static, u8> {
    let (sender, receiver) = channel(100);
    tokio::task::spawn_blocking(move || {
        let mut buffer = [0_u8; 2880 * 64];

        let mut bytes_read = 0;
        while bytes_read < bytes_to_read {
            let bytes =
                reader.read(&mut buffer[..(bytes_to_read - bytes_read).min(2880 * 64) as usize])?;
            bytes_read += bytes as u64;
            sender.blocking_send(buffer[..bytes].to_vec())?;
        }
        Ok::<(), Box<dyn std::error::Error + Send + Sync>>(())
    });

    let stream = ReceiverStream::new(receiver);

    stream.flat_map(|data| stream::iter(data)).boxed()
}