/*
- * Copyright 2016 Facebook, Inc.
+ * Copyright 2017 Facebook, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
}
nodes[sourceHandle].promise.setValue();
- auto that = shared_from_this();
- return nodes[sinkHandle].promise.getFuture().ensure([that] {}).then(
- [this, sourceHandle, sinkHandle]() {
- clean_state(sourceHandle, sinkHandle);
+ return nodes[sinkHandle].promise.getFuture().then(
+ [that = shared_from_this(), sourceHandle, sinkHandle]() {
+ that->clean_state(sourceHandle, sinkHandle);
});
}
std::vector<T> dep_states;
T result() {
return state;
- };
+ }
// execReset() runs DAG & clears all nodes except for source
void execReset() {
this->dag->go().get();
this->dag->reset();
- };
+ }
void exec() {
this->dag->go().get();
- };
- virtual void operator()(){};
+ }
+ virtual void operator()(){}
explicit FutureDAGFunctor(T init_val) : state(init_val) {}
FutureDAGFunctor() : state() {}
- virtual ~FutureDAGFunctor(){};
+ virtual ~FutureDAGFunctor(){}
};
-} // folly
+} // namespace folly