Unverified Commit dbd9f18e authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files
parent 5a32dbd0
Pipeline #17899 passed with stages
in 5 minutes and 27 seconds
......@@ -53,8 +53,15 @@ object App
None
}
}
.filter(record => filters.forall(f => f(record)))
.foldLeft(HashSet[DeleteMessage]())((agg, record) => agg + DeleteMessage(record, sessionId))
.filter(record => {
logger.info("Filtering")
filters.forall(f => f(record))
}
)
.foldLeft(HashSet[DeleteMessage]())((agg, record) => {
logger.info("Aggregating")
agg + DeleteMessage(record, sessionId)
})
)
.foreach(id => sendDelete(id))
} catch {
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment