in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/ProducerBatch.java [181:193]
private void setFutures(Result result) {
for (Thunk thunk : thunks) {
try {
if (result.isSuccessful()) {
thunk.future.set(result);
} else {
thunk.future.setException(new ResultFailedException(result));
}
} catch (Exception e) {
LOGGER.error("Failed to set future, groupKey={}, e=", groupKey, e);
}
}
}