Я довольно новичок в RxJS и пытался выяснить простой канал (toArray), но не могу заставить его работать. Каждый пример, который я видел, предполагает, что это должно работать:
import {toArray} from 'rxjs/operators';
import {of} from 'rxjs';
it('observable should generate array of length 3', done=>{
of(1,2,3).pipe(toArray).subscribe(val=> {
expect(val.length).toBe(3);
done();
});
});
Тем не менее, он просто выдает ошибку «.subscribe не функция»
package.json:
"rxjs": "^6.4.0",
"rxjs-compat": "^6.4.0"