Styjun

Can't connect to Internet in bash using Mac OS

Why is there a need to modify system call tables in linux?

Infinitely many hats

Why do Russians call their women expensive ("дорогая")?

What does it mean when you think without speaking?

Understanding STM32 datasheet regarding decoupling capacitors

Biblical Basis for 400 years of silence between old and new testament

Get LaTeX form from step by step solution

Do creatures all have the same statistics upon being reanimated via the Animate Dead spell?

Beginner's snake game using PyGame

Points within polygons in different projections

How can a single Member of the House block a Congressional bill?

Self-Preservation: How to DM NPCs that Love Living?

What does "Marchentalender" on the front of a postcard mean?

etoolbox: AtBeginEnvironment is not At Begin Environment

Could IPv6 make NAT / port numbers redundant?

Is there an evolutionary advantage to having two heads?

Why does the UK have more political parties than the US?

How crucial is a waifu game storyline?

Why would Lupin kill Pettigrew?

60s (or earlier) short story where each colony has one person who doesn't connect well with others who is there for being able to absorb knowledge

If a problem only occurs randomly once in every N times on average, how many tests do I have to perform to be certain that it's now fixed?

How to make the POV character sit on the sidelines without the reader getting bored

Is floating in space similar to falling under gravity?

StreamBuilder's snapshot is not giving all data emitted by Stream in Flutter

Flutter : Can I add a Header Row to a ListViewFlutter : Bad state: Stream has already been listened toEmit the data to parent Widget in FlutterFlutter Streams, how to access previously emitted data from the streamHow to return list of object in a stream on flutterflutter snackbar display based on streamhow to use Firebase snapshot with rxdart streamsStream (BLoC) doesn't emit values while used in TabBarViewFlutter - rxdart - Reading stream multiple timesHow to cache rxdart streams in flutter for infinite scroll

.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty height:90px;width:728px;box-sizing:border-box;

2

I am trying the below code to print 1, 2 and 3 on a Text widget. But the problem is its only printing 1 and 3. But by property concat should print all data sequentially right?

Stream<String> get concatStream => Observable.concat(
 [new Observable.just(1.toString()),
 new Observable.timer(2.toString(), new Duration(seconds: 1)),
 new Observable.just(3.toString())]);

The weird part is, if I use the below configuration. It's printing all the 3 values sequentially. What can be the problem?

Stream<String> get concatStream => Observable.concat([
 new Observable.just(1.toString()),
 new Observable.timer(2.toString(), new Duration(seconds: 2)),
 new Observable.timer(3.toString(),new Duration(seconds: 1))
 ]);

Code of my StreamBuilder:

return StreamBuilder(
 stream: getStream(),
 builder: (BuildContext context, AsyncSnapshot<String> snapshot) 
 if (snapshot.hasData) 
 print(snapshot.data);
 return Text(
 snapshot.data,
 textAlign: TextAlign.center,
 style: TextStyle(fontWeight: FontWeight.w300),
 );
 else if (snapshot.hasError) 
 return Text("Error");
 else 
 return CircularProgressIndicator();
 
 );

dart flutter rxdart

share|improve this question

asked Mar 24 at 9:41

XoXoXoXo

49611142

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  read StreamBuilder documentation: " The builder is called at the discretion of the Flutter pipeline, and will thus receive a timing-dependent sub-sequence of the snapshots that represent the interaction with the stream. As an example, when interacting with a stream producing the integers 0 through 9, the builder may be called with any ordered sub-sequence of the following snapshots that includes the last one (the one with ConnectionState.done):"
  
  – pskink
  Mar 24 at 9:48
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  Yeah now I got it. But don't you think its not a good approach to miss out some data. I was just scratching my head from past 2 hours over this funny behaviour. Btw thanks for that comment. But any idea how to resolve this if I want all the 3 values? @pskink
  
  – XoXo
  Mar 24 at 9:54
  

  
  
  
  


• 
  
  
  

  
  1
  

  
  
  
  
  
  

  
  
  simply Listen() that Stream
  
  – pskink
  Mar 24 at 9:56
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  maybe there is another way in async package? or use Stream#transform which simply returns the same element?
  
  – pskink
  Mar 24 at 10:11
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  Actually the Listen() method as mentioned by you didn't work. I was checking with the 2nd configuration which was already working.
  
  – XoXo
  Mar 24 at 10:25
  

  
  
  
  

 | 
show 2 more comments

2

I am trying the below code to print 1, 2 and 3 on a Text widget. But the problem is its only printing 1 and 3. But by property concat should print all data sequentially right?

Stream<String> get concatStream => Observable.concat(
 [new Observable.just(1.toString()),
 new Observable.timer(2.toString(), new Duration(seconds: 1)),
 new Observable.just(3.toString())]);

The weird part is, if I use the below configuration. It's printing all the 3 values sequentially. What can be the problem?

Stream<String> get concatStream => Observable.concat([
 new Observable.just(1.toString()),
 new Observable.timer(2.toString(), new Duration(seconds: 2)),
 new Observable.timer(3.toString(),new Duration(seconds: 1))
 ]);

Code of my StreamBuilder:

return StreamBuilder(
 stream: getStream(),
 builder: (BuildContext context, AsyncSnapshot<String> snapshot) 
 if (snapshot.hasData) 
 print(snapshot.data);
 return Text(
 snapshot.data,
 textAlign: TextAlign.center,
 style: TextStyle(fontWeight: FontWeight.w300),
 );
 else if (snapshot.hasError) 
 return Text("Error");
 else 
 return CircularProgressIndicator();
 
 );

dart flutter rxdart

share|improve this question

asked Mar 24 at 9:41

XoXoXoXo

49611142

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  read StreamBuilder documentation: " The builder is called at the discretion of the Flutter pipeline, and will thus receive a timing-dependent sub-sequence of the snapshots that represent the interaction with the stream. As an example, when interacting with a stream producing the integers 0 through 9, the builder may be called with any ordered sub-sequence of the following snapshots that includes the last one (the one with ConnectionState.done):"
  
  – pskink
  Mar 24 at 9:48
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  Yeah now I got it. But don't you think its not a good approach to miss out some data. I was just scratching my head from past 2 hours over this funny behaviour. Btw thanks for that comment. But any idea how to resolve this if I want all the 3 values? @pskink
  
  – XoXo
  Mar 24 at 9:54
  

  
  
  
  


• 
  
  
  

  
  1
  

  
  
  
  
  
  

  
  
  simply Listen() that Stream
  
  – pskink
  Mar 24 at 9:56
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  maybe there is another way in async package? or use Stream#transform which simply returns the same element?
  
  – pskink
  Mar 24 at 10:11
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  Actually the Listen() method as mentioned by you didn't work. I was checking with the 2nd configuration which was already working.
  
  – XoXo
  Mar 24 at 10:25
  

  
  
  
  

 | 
show 2 more comments

I am trying the below code to print 1, 2 and 3 on a Text widget. But the problem is its only printing 1 and 3. But by property concat should print all data sequentially right?

Stream<String> get concatStream => Observable.concat(
 [new Observable.just(1.toString()),
 new Observable.timer(2.toString(), new Duration(seconds: 1)),
 new Observable.just(3.toString())]);

The weird part is, if I use the below configuration. It's printing all the 3 values sequentially. What can be the problem?

Stream<String> get concatStream => Observable.concat([
 new Observable.just(1.toString()),
 new Observable.timer(2.toString(), new Duration(seconds: 2)),
 new Observable.timer(3.toString(),new Duration(seconds: 1))
 ]);

Code of my StreamBuilder:

return StreamBuilder(
 stream: getStream(),
 builder: (BuildContext context, AsyncSnapshot<String> snapshot) 
 if (snapshot.hasData) 
 print(snapshot.data);
 return Text(
 snapshot.data,
 textAlign: TextAlign.center,
 style: TextStyle(fontWeight: FontWeight.w300),
 );
 else if (snapshot.hasError) 
 return Text("Error");
 else 
 return CircularProgressIndicator();
 
 );

dart flutter rxdart

share|improve this question

asked Mar 24 at 9:41

XoXoXoXo

49611142

Stream<String> get concatStream => Observable.concat(
 [new Observable.just(1.toString()),
 new Observable.timer(2.toString(), new Duration(seconds: 1)),
 new Observable.just(3.toString())]);

Stream<String> get concatStream => Observable.concat([
 new Observable.just(1.toString()),
 new Observable.timer(2.toString(), new Duration(seconds: 2)),
 new Observable.timer(3.toString(),new Duration(seconds: 1))
 ]);

return StreamBuilder(
 stream: getStream(),
 builder: (BuildContext context, AsyncSnapshot<String> snapshot) 
 if (snapshot.hasData) 
 print(snapshot.data);
 return Text(
 snapshot.data,
 textAlign: TextAlign.center,
 style: TextStyle(fontWeight: FontWeight.w300),
 );
 else if (snapshot.hasError) 
 return Text("Error");
 else 
 return CircularProgressIndicator();
 
 );

dart flutter rxdart

dart flutter rxdart

share|improve this question

asked Mar 24 at 9:41

XoXoXoXo

49611142

share|improve this question

asked Mar 24 at 9:41

XoXoXoXo

49611142

asked Mar 24 at 9:41

XoXoXoXo

49611142

asked Mar 24 at 9:41

XoXoXoXo

49611142