Path path = ...
NdjsonToMessageReader.Deserializer deserializer = ...
try (NdjsonToMessageReader reader = new NdjsonToMessageReader(newInputStream(path), deserializer)) {
return reader.lines()
// Do something with messages
.collect(Collectors.toList());
}Path path = ...
MessageToNdjsonWriter.Serializer serializer = ...
try(MessageToNdjsonWriter writer = new MessageToNdjsonWriter(newOutputStream(path), serializer)){
for(Envelope envelope : messages){
writer.write(envelope);
}
}See Unit tests for more examples.