Collection<CanCommit> messages = registry.createCanCommitMessages(txId, tip, schema);
// FIXME: Optimize empty collection list with pre-created futures, containing success.
Future<Iterable<Object>> canCommitsFuture =
Futures.traverse(messages, new Function<CanCommit, Future<Object>>() {
@Override
Collection<CanCommit> messages = registry.createCanCommitMessages(txId, tip, schema);
// FIXME: Optimize empty collection list with pre-created futures, containing success.
Future<Iterable<Object>> canCommitsFuture =
Futures.traverse(messages, new Function<CanCommit, Future<Object>>() {
@Override