Некоторые пояснения Completer

Question

Привет всем

У меня есть один класс «Пример», которому нужно сделать некоторые вычисления. Я вызываю start(), которые вызывают _next(). Во время вычисления _next() вызывает себя пару раз, но в моем примере я имитирую это с помощью таймера. Вот мой код

import "dart:async"; 


main() { 

    Example ex = new Example(); 

    for (var i = 0 ; i < 3 ; i++) { 
     ex.start().then((nbr) { 
      print(nbr); 
     }); 
    } 

} 

class Example { 

    /// for _next 
    Completer _insideCompleter; 

    /// from start() to outside 
    Completer _outsideCompleter; 

    Example(); 

    /// start is just a better public api than next when we start the exercise 
    Future<int> start() { 

     _insideCompleter = new Completer(); 
     _outsideCompleter = new Completer(); 


     _next().then((int value) { 
      print("value: $value"); 
      _outsideCompleter.complete(value); 

     }).catchError((message) { 
      print("information: $message"); 
     }); 

     return _outsideCompleter.future; 
    } 


    /// _next handle the flow with the status 
    Future<int> _next() { 

     new Timer(new Duration(seconds: 6),() { 
      _insideCompleter.complete(15); 
     }); 

     return _insideCompleter.future; 
    } 
} 

она заканчивается: плохое состояние: Будущее уже завершено. но как вы можете видеть в начале(). Завершение воссоздается с новым. Поэтому я не понимаю, почему он уже завершен.

Если кто-нибудь может объяснить, почему это не правильно закодировать так, и, возможно, дать мне некоторые интересные ссылки, было бы здорово

Ура!

Answer 1

Я не совсем уверен, что ваше намерение с кодом, но я думаю, вы должны либо

Example ex = new Example(); 

for (var i = 0 ; i < 3 ; i++) { // create a new Example() for each iteration here 
    ex.start().then((nbr) {  // or ensure that the next iteration is not executed 
     print(nbr);    // before the previous is completed. 
    }); 
} 

с этим кодом ex.start() называются 3 раза до того, как первый вызов завершен.

Answer 2

Здесь главный вопрос о завершивших называемых в функции обратного вызова

_next().then((int value) { 
      print("value: $value"); 
      _outsideCompleter.complete(value); // this line 

     }) 

и

new Timer(new Duration(seconds: 6),() { 
      _insideCompleter.complete(15); // this line 
     }); 

Поскольку это 2 функции называется после цикла и вашего завершившима является атрибутом, все обратные вызовы будут использовать последние _outsideCompleter и _insideCompleter.

Таким образом, после чем один из обратного вызова есть «потреблять» ваш завершающего, другие будут создавать исключение «плохое состояние: Будущее уже завершено»

здесь версия, которая работает

import "dart:async"; 


main() { 

    Example ex = new Example(); 

    for (var i = 0 ; i < 3 ; i++) { 
    ex.start().then((nbr) { 
     print(nbr); 
    }); 
    } 

} 

class Example { 

    Example(); 

    /// start is just a better public api than next when we start the exercise 
    Future<int> start() { 

    var outsideCompleter = new Completer(); // create localy each times 


    _next().then((int value) { 
     print("value: $value"); 
     outsideCompleter.complete(value); 

    }).catchError((message) { 
     print("information: $message"); 
    }); 

    return outsideCompleter.future; 
    } 


    /// _next handle the flow with the status 
    Future<int> _next() { 
    var insideCompleter = new Completer(); // create localy each times 

    new Timer(new Duration(seconds: 6),() { 
     insideCompleter.complete(15); 
    }); 

    return insideCompleter.future; 
    } 
}