- if (current_segment_id_ == (logic_mux_data_->logic_segments().size() - 1)) {
- // Wait for more input data if we're processing the currently last segment
- unique_lock<mutex> input_wait_lock(input_mutex_);
- decode_input_cond_.wait(input_wait_lock);
- }