source_2.rs

                recv(from_processor_receiver) -> msg => {
                    let _ = work_sender.send(SourceMsg::TickAdjusted);
                    match msg {
                        Ok(RegulateSourceMsg::SlowDown) => {
                            current_ticker_duration = match current_ticker_duration {
                                Some(tick) => {
                                    if tick > 100 {
                                        Some(100)
                                    } else {
                                        Some(tick * 2)
                                    }
                                },
                                None => continue,
                            };
                            ticker = tick(Duration::from_millis(current_ticker_duration.unwrap()));
                        },
                        Ok(RegulateSourceMsg::SpeedUp) => {
                            current_ticker_duration = match current_ticker_duration {
                                Some(tick) if tick > 2 => Some(tick / 2),
                                Some(tick) => Some(tick),
                                // If we're in "stopped" mode, re-start slowly.
                                None => Some(100),
                            };
                            ticker = tick(Duration::from_millis(current_ticker_duration.unwrap()));
                        },
                        Ok(RegulateSourceMsg::Stop) => {
                            current_ticker_duration = None;
                            ticker = never();
                        },
                        _ => panic!("Error receiving a RegulateSourceMsg."),
                    }
                }