Method tx

datafusion/physical-plan/src/stream.rs:76–78

Get a handle for sending data to the output

(&self)

    /// Get a handle for sending data to the output
    pub fn tx(&self) -> Sender<Result<O>> {
        self.tx.clone()
    }

    /// Spawn task that will be aborted if this builder (or the stream
    /// built from it) are dropped