Struct tfrecord::writer::RecordWriter

pub struct RecordWriter<T, W> where
    T: GenericRecord,  { /* fields omitted */ }

The writer type.

It provides blocing RecordWriter::send and analogues RecordWriter::send_async methods to write records.

Implementations

impl<T, W> RecordWriter<T, W> where
    T: GenericRecord,
    W: Write, 

pub fn send(&mut self, record: T) -> Result<(), Error>

Write a record.

The method is enabled if the underlying writer implements Write.

pub fn flush(&mut self) -> Result<(), Error>

Flush the output stream.

impl<T, W> RecordWriter<T, W> where
    T: GenericRecord,
    W: AsyncWriteExt + Unpin, 

pub async fn send_async(&mut self, record: T) -> Result<(), Error>

Write a record.

The method is enabled if the underlying writer implements [AsyncWriteExt].

pub async fn flush_async(&mut self) -> Result<(), Error>

Flush the output stream asynchronously.

Trait Implementations

impl<T: Clone, W: Clone> Clone for RecordWriter<T, W> where
    T: GenericRecord, 

fn clone(&self) -> RecordWriter<T, W>

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug, W: Debug> Debug for RecordWriter<T, W> where
    T: GenericRecord, 

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Eq, W: Eq> Eq for RecordWriter<T, W> where
    T: GenericRecord, 

impl<T: Hash, W: Hash> Hash for RecordWriter<T, W> where
    T: GenericRecord, 

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

pub fn hash_slice<H>(data: &[Self], state: &mut H) where
    H: Hasher, 

Feeds a slice of this type into the given Hasher.

impl<T: PartialEq, W: PartialEq> PartialEq<RecordWriter<T, W>> for RecordWriter<T, W> where
    T: GenericRecord, 

fn eq(&self, other: &RecordWriter<T, W>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &RecordWriter<T, W>) -> bool

This method tests for !=.

impl<T, W> StructuralEq for RecordWriter<T, W> where
    T: GenericRecord, 

impl<T, W> StructuralPartialEq for RecordWriter<T, W> where
    T: GenericRecord,