protected JsonParser parser = new JsonParser();
protected final FormatMapper format;
- public Formatter(FormatMapper format) {
+ public Formatter (FormatMapper format) {
this.format = format;
}
} else {
stream = vertices.stream();
}
-
+ final boolean isParallel = stream.isParallel();
stream.map(v -> {
try {
return Optional.<JsonObject>of(format.formatObject(v));
return Optional.<JsonObject>empty();
}).forEach(obj -> {
if (obj.isPresent()) {
- synchronized (body) {
+ if (isParallel) {
+ synchronized (body) {
+ body.add(obj.get());
+ }
+ } else {
body.add(obj.get());
}
}