Skip to content

Instantly share code, notes, and snippets.

@GaetanoPiazzolla

GaetanoPiazzolla/search-flux.java

Created September 18, 2021 11:21
Show Gist options
  • Save GaetanoPiazzolla/a062860defaf93c15453614055fc5b37 to your computer and use it in GitHub Desktop.
Save GaetanoPiazzolla/a062860defaf93c15453614055fc5b37 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
search-flux.java
import reactor.core.publisher.*;
import java.nio.file.Path;
public Flux<String> searchReactive() {
Path ipPath = Path.of(pathFile);
return Flux.using(
() -> Files.lines(ipPath),
Flux::fromStream,
Stream::close)
.filter(l -> l.contains(SEARCH_TOKEN))
.map(s -> s + "\r\n");
}
@GaetanoPiazzolla
Copy link
Author

related to medium article https://gae-piaz.medium.com/search-string-in-file-with-java-as-fast-as-possible-fedafdc7a3ee

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment