다트 스트림 구독 취소

Question

안녕하세요!

저는 Dart에서 스트림의 동작을 이해하려고합니다.

: 우리는 Publisher

class Publisher { 

    StreamController<String> _publishCtrl = new StreamController<String>(); 
    Stream<String> onPublish; 

    Publisher() { 
     onPublish = _publishCtrl.stream.asBroadcastStream(); 
    } 

    void publish(String s) { 
     _publishCtrl.add(s); 
    } 
} 

그리고

class Reader { 
    String name; 
    Reader(this.name); 
    read(String s) { 
     print("My name is $name. I read string '$s'"); 
    } 
} 

Reader 그리고 간단한 함수 main()이

1. :
   여기 은 간단한 예입니다 코드의 결과

나는 독자 John 5 콘솔 메시지와 독자 Smith 5 메시지를 얻을.

My name is John. I read string 'Test message 0' 
My name is Smith. I read string 'Test message 0' 
My name is John. I read string 'Test message 1' 
My name is Smith. I read string 'Test message 1' 
My name is John. I read string 'Test message 2' 
My name is Smith. I read string 'Test message 2' 
My name is John. I read string 'Test message 3' 
My name is Smith. I read string 'Test message 3' 
My name is John. I read string 'Test message 4' 
My name is Smith. I read string 'Test message 4' 

모든 것이 올바르게 작동합니다. 그러나 사이클 for을 변경하려고 시도하면 2 단계 리더 Smith이 메시지를 받으면 메시지에 리더 John 만 수신됩니다.
여기 함수 main()을 변경하는 예입니다

main() { 
     Publisher publisher = new Publisher(); 

     Reader john = new Reader('John'); 
     Reader smith = new Reader('Smith'); 

     publisher.onPublish.listen(john.read); 
     var smithSub = publisher.onPublish.listen(smith.read); 

     for (var i = 0; i < 5; i++) { 
      publisher.publish("Test message $i"); 

      if (i > 2) { 
       smithSub.cancel(); 
      } 
     } 
    } 

이 코드를 실행하면 콘솔 것이다 존들만 게시물 : 나는 3 메시지가 있어야한다고 생각

My name is John. I read string 'Test message 0' 
My name is John. I read string 'Test message 1' 
My name is John. I read string 'Test message 2' 
My name is John. I read string 'Test message 3' 
My name is John. I read string 'Test message 4' 

그러나 독자로부터 스미스.

내가 아는 전부인지 말해 주시겠습니까? 그렇지 않다면 왜 이런 일이 일어나는지 이해해주십시오.

대단히 감사합니다.

Answer 1

동기화 StreamController

StreamController<String> _publishCtrl = new StreamController<String>(sync: true); 

을 만들거나 컨트롤러가 새

int i = 0; 
    Future.doWhile(() { 
    i++; 

    publisher.publish("Test message $i"); 

    if (i > 2) { 
     subscriptions 
     ..forEach((s) => s.cancel()) 
     ..clear(); 
    } 
    return i < 5; 
    }