fix dyn stuff

This commit is contained in:
Graham Christensen 2019-11-02 17:55:50 +01:00
parent a4dc3d020b
commit 78d1395ce5
No known key found for this signature in database
GPG key ID: ACA1C1D120C83D5C
4 changed files with 7 additions and 7 deletions

View file

@ -11,7 +11,7 @@ pub struct NotifyWorker<T: SimpleNotifyWorker> {
pub trait SimpleNotifyWorker {
type J;
fn consumer(&self, job: &Self::J, notifier: &mut NotificationReceiver);
fn consumer(&self, job: &Self::J, notifier: &mut dyn NotificationReceiver);
fn msg_to_job(
&self,

View file

@ -110,7 +110,7 @@ type Package = String;
type Architecture = String;
type OutPath = String;
pub fn parse_lines(data: &mut BufRead) -> PackageOutPaths {
pub fn parse_lines(data: &mut dyn BufRead) -> PackageOutPaths {
data.lines()
.filter_map(|line| match line {
Ok(line) => Some(line),

View file

@ -41,7 +41,7 @@ impl BuildWorker {
fn actions<'a, 'b>(
&self,
job: &'b buildjob::BuildJob,
receiver: &'a mut notifyworker::NotificationReceiver,
receiver: &'a mut dyn notifyworker::NotificationReceiver,
) -> JobActions<'a, 'b> {
JobActions::new(&self.system, &self.identity, job, receiver)
}
@ -50,7 +50,7 @@ impl BuildWorker {
pub struct JobActions<'a, 'b> {
system: String,
identity: String,
receiver: &'a mut notifyworker::NotificationReceiver,
receiver: &'a mut dyn notifyworker::NotificationReceiver,
job: &'b buildjob::BuildJob,
line_counter: u64,
snippet_log: VecDeque<String>,
@ -66,7 +66,7 @@ impl<'a, 'b> JobActions<'a, 'b> {
system: &str,
identity: &str,
job: &'b buildjob::BuildJob,
receiver: &'a mut notifyworker::NotificationReceiver,
receiver: &'a mut dyn notifyworker::NotificationReceiver,
) -> JobActions<'a, 'b> {
let (log_exchange, log_routing_key) = job
.logs
@ -279,7 +279,7 @@ impl notifyworker::SimpleNotifyWorker for BuildWorker {
fn consumer(
&self,
job: &buildjob::BuildJob,
notifier: &mut notifyworker::NotificationReceiver,
notifier: &mut dyn notifyworker::NotificationReceiver,
) {
let mut actions = self.actions(&job, notifier);

View file

@ -156,7 +156,7 @@ impl<E: stats::SysEvents + 'static> worker::SimpleWorker for EvaluationWorker<E>
}
};
let mut evaluation_strategy: Box<eval::EvaluationStrategy> = if job.is_nixpkgs() {
let mut evaluation_strategy: Box<dyn eval::EvaluationStrategy> = if job.is_nixpkgs() {
Box::new(eval::NixpkgsStrategy::new(
&job,
&pull,