Trait nu_protocol::IntoInterruptiblePipelineData

pub trait IntoInterruptiblePipelineData {
    fn into_pipeline_data(self, ctrlc: Option<Arc<AtomicBool>>) -> PipelineData;
    fn into_pipeline_data_with_metadata(
        self,
        metadata: PipelineMetadata,
        ctrlc: Option<Arc<AtomicBool>>
    ) -> PipelineData;
}

Required Methods

fn into_pipeline_data(self, ctrlc: Option<Arc<AtomicBool>>) -> PipelineData

fn into_pipeline_data_with_metadata(
    self,
    metadata: PipelineMetadata,
    ctrlc: Option<Arc<AtomicBool>>
) -> PipelineData

Implementors

impl<I> IntoInterruptiblePipelineData for Iwhere
    I: IntoIterator + Send + 'static,
    I::IntoIter: Send + 'static,
    <I::IntoIter as Iterator>::Item: Into<Value>,