Re: A parallel HttpClient sendAync question

2018-11-13 Thread Weijun Wang
> > That's what I would use too. Though Chris Y.'s suggestion below > should also work: > > On 13/11/2018 03:41, Chris Yin wrote: > lines.flapMap(x -> > Stream.ofNullable(findURIFrom(x))) >>.map(l -> download(c, l)) >>.collect(Collectors.toList()) >>.forEach(f -> f.join()); > > sinc

Re: A parallel HttpClient sendAync question

2018-11-13 Thread Daniel Fuchs
Hi Max, On 13/11/2018 02:35, Weijun Wang wrote: I'm scanning a file and downloading links inside: lines.flapMap(x -> Stream.ofNullable(findURIFrom(x))) .map(l -> download(c, l)) .forEach(f -> f.join()); CompletableFuture> download(HttpClient c, URI link) { return c.sendAsync(H

Re: A parallel HttpClient sendAync question

2018-11-12 Thread Weijun Wang
> On Nov 13, 2018, at 11:41 AM, Chris Yin wrote: > >> >> On 13 Nov 2018, at 10:35 AM, Weijun Wang wrote: >> >> I'm scanning a file and downloading links inside: >> >> lines.flapMap(x -> Stream.ofNullable(findURIFrom(x))) >>.map(l -> download(c, l)) >>.forEach(f -> f.join()); >> >>

Re: A parallel HttpClient sendAync question

2018-11-12 Thread Chris Yin
> On 13 Nov 2018, at 10:35 AM, Weijun Wang wrote: > > I'm scanning a file and downloading links inside: > > lines.flapMap(x -> Stream.ofNullable(findURIFrom(x))) > .map(l -> download(c, l)) > .forEach(f -> f.join()); > > CompletableFuture> download(HttpClient c, URI link) { >retur

Re: A parallel HttpClient sendAync question

2018-11-12 Thread Pavel Rappo
> On 13 Nov 2018, at 02:35, Weijun Wang wrote: > > I'm scanning a file and downloading links inside: > > lines.flapMap(x -> Stream.ofNullable(findURIFrom(x))) > .map(l -> download(c, l)) > .forEach(f -> f.join()); > > CompletableFuture> download(HttpClient c, URI link) { >return c.s