This commit is contained in:
hengyunabc
2019-05-14 19:50:32 +08:00
parent a55034ad12
commit 487742dfb0
2 changed files with 8 additions and 12 deletions
@@ -607,12 +607,10 @@ public class ProcessImpl implements Process {
if (statisticsHandler != null && flushHandlerChain != null) {
String data = statisticsHandler.result();
if (flushHandlerChain != null) {
for (Function<String, String> function : flushHandlerChain) {
data = function.apply(data);
if (function instanceof StatisticsFunction) {
data = ((StatisticsFunction) function).result();
}
for (Function<String, String> function : flushHandlerChain) {
data = function.apply(data);
if (function instanceof StatisticsFunction) {
data = ((StatisticsFunction) function).result();
}
}
}