1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/mobile/android/base/sync/repositories/delegates/DeferredRepositorySessionBeginDelegate.java Wed Dec 31 06:09:35 2014 +0100
1.3 @@ -0,0 +1,46 @@
1.4 +/* This Source Code Form is subject to the terms of the Mozilla Public
1.5 + * License, v. 2.0. If a copy of the MPL was not distributed with this
1.6 + * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
1.7 +
1.8 +package org.mozilla.gecko.sync.repositories.delegates;
1.9 +
1.10 +import java.util.concurrent.ExecutorService;
1.11 +
1.12 +import org.mozilla.gecko.sync.repositories.RepositorySession;
1.13 +
1.14 +public class DeferredRepositorySessionBeginDelegate implements RepositorySessionBeginDelegate {
1.15 + private RepositorySessionBeginDelegate inner;
1.16 + private ExecutorService executor;
1.17 + public DeferredRepositorySessionBeginDelegate(final RepositorySessionBeginDelegate inner, final ExecutorService executor) {
1.18 + this.inner = inner;
1.19 + this.executor = executor;
1.20 + }
1.21 +
1.22 + @Override
1.23 + public void onBeginSucceeded(final RepositorySession session) {
1.24 + executor.execute(new Runnable() {
1.25 + @Override
1.26 + public void run() {
1.27 + inner.onBeginSucceeded(session);
1.28 + }
1.29 + });
1.30 + }
1.31 +
1.32 + @Override
1.33 + public void onBeginFailed(final Exception ex) {
1.34 + executor.execute(new Runnable() {
1.35 + @Override
1.36 + public void run() {
1.37 + inner.onBeginFailed(ex);
1.38 + }
1.39 + });
1.40 + }
1.41 +
1.42 + @Override
1.43 + public RepositorySessionBeginDelegate deferredBeginDelegate(ExecutorService newExecutor) {
1.44 + if (newExecutor == executor) {
1.45 + return this;
1.46 + }
1.47 + throw new IllegalArgumentException("Can't re-defer this delegate.");
1.48 + }
1.49 +}
1.50 \ No newline at end of file
