- }, new Callback<DatabaseException>() {
- @Override
- public void run(DatabaseException e) {
- if (e != null) {
- if (listener != null)
- listener.onFailure(e);
- else
- ErrorLogger.defaultLogError(e);
- } else {
- attachStateListener(session, experiment, _run.get());
- if (successCallback != null)
- successCallback.accept(_run.get());
- if (listener != null)
- listener.onExperimentActivated(experiment);
- }
+ }, e -> {
+ if (e != null) {
+ if (listener != null)
+ listener.onFailure(e);
+ else
+ ErrorLogger.defaultLogError(e);
+ } else {
+ attachStateListener(session, experiment, _run.get());
+ if (successCallback != null)
+ successCallback.accept(_run.get());
+ if (listener != null)
+ listener.onExperimentActivated(experiment);