pub fn step(&self) -> Result<(), SchedulerError> {
        // TODO: Add a runtime check to prevent re-entering this method from an
        // operator.

        self.executor.run(&self.circuit)
    }
/// Function that drives the execution of the circuit.
///
/// Every call to `step()` corresponds to one tick of the global logical
/// clock and causes each operator in the circuit to get evaluated once,
/// consuming one value from each of its input streams.
Function that drives the execution of the circuit.
Every call to `step()` corresponds to one tick of the global logical
clock and causes each operator in the circuit to get evaluated once,
consuming one value from each of its input streams.
Function that drives the execution of the circuit . Every call to ` step () ` corresponds to one tick of the global logical clock and causes each operator in the circuit to get evaluated once consuming one value from each of its input streams .
pub fn step(&self) -> Result<(), SchedulerError> {
        // TODO: Add a runtime check to prevent re-entering this method from an
        // operator.
        self.executor.run(&self.circuit)
    }
pub fn step ( & self ) -> Result < ( ) , SchedulerError > { // TODO: Add a runtime check to prevent re-entering this method from an // operator. self . executor . run ( & self . circuit ) }
Function that drives the execution of the circuit.
Function that drives the execution of the circuit .
&self