конвертировать операторы rxjs5 в rxjs6 - PullRequest
Новая
       18

конвертировать операторы rxjs5 в rxjs6

0 голосов
/ 26 июня 2019

у меня есть следующий код, написанный на rxjs5, и он сломался с rxjs6

Может кто-нибудь помочь мне с записью в rxjs 6

его сбой MergeMap, получая groupedObserable, который не имеет метода count и вместетакже метод фильтра не существует. 

list [

{id: '1', type: 't1',  name: 'f1', des:'d1', selected: true},
{id: '2', type: 't1',  name: 'f2', des:'d2', selected: false},

{id: '3', type: 't1',  name: 'f11', des:'d11', selected: false},
{id: '4', type: 't1',  name: 'f22', des:'d22', selected: true},
]

Observable.from(list)
.filter(a => a.name != null)
.groupBy(i => i.type)
.mergeMap(list => {
let count = list.count;
let selectedCount = 0;
list.filter( f => f.selected).count.subscribe(c => selectedCount = c)
return count.map(count =>  {
   {
     key: list.key,
     totalCount: count,
     selected: selectedCount
   }
}
}).reduce((x, y) => {
x.isValid = x.selectedCount > 0 
return x;
}).subscribe(r => {
  console.log(r + 'any item selected')
}
)

, когда я пытался записать в rxjs6 только прогресс, который мне удалось достичь, заранее спасибо. 

from(list)
    .pipe(
    filter( s=> s.name != null) ,
    groupBy(i => i.type),
    mergeMap( (value, index) => {
      value.count // that's where it starts to fail
    }
    ))

1 Ответ

1 голос
/ 26 июня 2019

Эквивалентный код rxjs6 должен быть таким: 

from(list)
      .pipe(
        filter(a => a.name != null),
        groupBy(i => i.type),
        mergeMap((p) => {
          return p.pipe(
                    filter(f => f.selected),
                    count(),
                    mergeMap(c => {
                      return p.pipe(
                        count(),
                        map(totalCount => {
                          return {
                            key: p.key,
                            totalCount: totalCount,
                            selected: c
                          };
                        })
                      );
                    })
                );
        }),
        reduce((x, y) => {
          //please adjust your code here as i could not see isValid on x
          x.isValid = x.selectedCount > 0; 
          return x;
         })
      ).subscribe(r => {
        console.log(r + 'any item selected')
      }
      )

Надеюсь, это даст представление о том, как действовать.

...