dbcrossbarlib 0.1.0

Library for copying data between databases (pre-release)
1
2
3
4
5
6
7
8
9
10
11

//! Our basic data representation.

use crate::common::*;

/// A stream of CSV data, with a unique name.
pub struct CsvStream {
    /// The name of this stream.
    pub name: String,
    /// A reader associated with this stream.
    pub data: Box<dyn Stream<Item = BytesMut, Error = Error> + Send + 'static>,
}