public Observable syncWorkflows()

in app/src/main/java/org/apache/taverna/mobile/data/local/DBHelper.java [52:70]

• 16 lines of code
• 3 McCabe index (conditional complexity)

    public Observable<Workflows> syncWorkflows(final Workflows workflows) {
        return Observable.defer(new Callable<ObservableSource<? extends Workflows>>() {
            @Override
            public ObservableSource<? extends Workflows> call() throws Exception {

                for (Workflow workflow : workflows.getWorkflowList()) {
                    if (!workflow.exists()) {
                        workflow.setFavourite(false);
                        workflow.save();
                    } else {

                        updateWorkflow(workflow).save();
                    }
                }

                return Observable.just(workflows);
            }
        });
    }