fixed StreamController flow to work like pluckr