return Stream.fromEffect(this._execute()).pipe(
Stream.flatMap((page: Page<Project>) => {
if (page.isLastPage) {
return Stream.fromIterable(page.result);
}
return Stream.concat(Stream.fromIterable(page.result), this.stream(offset + this.limit));
})
);
return Stream.fromEffect(this._execute()).pipe(
Stream.flatMap((page: Page<Project>) => {
if (page.isLastPage) {
return Stream.fromIterable(page.result);
}
return Stream.concat(Stream.fromIterable(page.result), this.stream(offset + this.limit));
})
);