gistfile1.rs

trait Subscriber<Input> {
...


trait OutputStrategy<'a, Output> {
    fn can_continue(&self) -> bool;
    fn send(&self, val: Result<Output, &str>);
    fn accept(&mut self, sub: &'a Subscriber<Output> +'a) -> Option<uint>;
}


impl<'a, O> OutputStrategy<'a, O> for SingleOutputStrategy<'a, O> {

    fn accept(&mut self, sub: &'a Subscriber<O>) -> Option<uint> {
        match self.subscriber {
            Some(_) => { sub.on_error("SubscriptionsFull"); 
                         None }
            None    => { self.subscriber = Some((Subscription::new(), sub));
                         sub.on_subscribe(self.subscriber.as_ref().unwrap().ref0());
                         Some(1) }
        }
    }

...
}


impl<'a, 'b, I, O, Iter> Publisher<'a, O> for IterPublisher<'a, 'b, I, O, Iter> where Iter: Iterator<I> {

    fn subscribe(&mut self, s: &'a Subscriber<O> +'a ) {
        let st = &mut self.outstrategy;
        match st.accept(s) {
            Some(i) => { st.on_request(|i| self.request(i)); st.on_cancel(|| self.cancel()); }
            None    => {}
        }
    }
}



155:27 error: cannot infer an appropriate lifetime for lifetime parameter `'a` due to conflicting requirements
       match st.accept(s) {
                                                             ^~~~~~~~~~~~
159:6 help: consider using an explicit lifetime parameter as shown: fn subscribe(&mut self, s: &'a Subscriber<O>+ 'a)
     fn subscribe(&mut self, s: &'a Subscriber<O> +'a ) {
         let st = &mut self.outstrategy;
         match st.accept(s) {
             Some(i) => { st.on_request(|i| self.request(i)); st.on_cancel(|| self.cancel()); }
             None    => {}
         }