Дарт: поток зависит от другого потока - PullRequest
Новая
       5

Дарт: поток зависит от другого потока

0 голосов
/ 08 января 2020

У меня есть поток Stream<List<String>> aStream, он содержит ссылки. Мне нужен поток Stream<List<T>> bStream, который запускается при изменении ссылок и изменении содержимого ссылки.

На данный момент я попытался: `

await for(List aList in aStream){
      yield* StreamGroup.merge(aList.entries.map((String reference){
        return refrencefunction(aString);
      }));
    }

`

Спасибо за вашу помощь

1 Ответ

0 голосов
/ 10 января 2020

Если refrencefunction возвращает Stream для каждой ссылки, и вы хотите получить List<T>, содержащую все текущие ссылочные значения, когда изменяется любое из ссылочных значений, вам придется управлять потоком подписаться на каждую ссылку и хранить копию последнего значения для каждой ссылки. Что, боюсь, не совсем уместится в одной строке: -)

...