This repository was archived by the owner on Sep 26, 2024. It is now read-only.
This repository was archived by the owner on Sep 26, 2024. It is now read-only.
Open
Description
have hit a problem that I'm struggling to figure out.
I'm basically wanting to merge 2 file streams in an interleaved fashion - we have 2 feed files containing data from overlapping times..
I was expecting that flatMap would interleave streams from all the files, but it looks like its very much sequential :/
.flatMap(file -> {
System.err.format("FILE: %s\n", file.getName());
return Streams.nmeaFrom(file);
})
What have I missed?