1 files changed, 0 insertions, 116 deletions
diff --git a/mojo/public/java/bindings/src/org/chromium/mojo/bindings/AutoCloseableRouter.java b/mojo/public/java/bindings/src/org/chromium/mojo/bindings/AutoCloseableRouter.java
deleted file mode 100644
index 8a83be9..0000000
--- a/mojo/public/java/bindings/src/org/chromium/mojo/bindings/AutoCloseableRouter.java
+++ /dev/null
@@ -1,116 +0,0 @@
-// Copyright 2014 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-package org.chromium.mojo.bindings;
-
-import org.chromium.mojo.system.Core;
-import org.chromium.mojo.system.MessagePipeHandle;
-
-import java.util.concurrent.Executor;
-
-/**
- * Wrapper around {@link Router} that will close the connection when not referenced anymore.
- */
-class AutoCloseableRouter implements Router {
-
-    /**
-     * The underlying router.
-     */
-    private final Router mRouter;
-
-    /**
-     * The executor to close the underlying router.
-     */
-    private final Executor mExecutor;
-
-    /**
-     * Flags to keep track if this router has been correctly closed.
-     */
-    private boolean mClosed;
-
-    /**
-     * Constructor.
-     */
-    public AutoCloseableRouter(Core core, Router router) {
-        mRouter = router;
-        mExecutor = ExecutorFactory.getExecutorForCurrentThread(core);
-    }
-
-    /**
-     * @see Router#setIncomingMessageReceiver(MessageReceiverWithResponder)
-     */
-    @Override
-    public void setIncomingMessageReceiver(MessageReceiverWithResponder incomingMessageReceiver) {
-        mRouter.setIncomingMessageReceiver(incomingMessageReceiver);
-    }
-
-    /**
-     * @see HandleOwner#passHandle()
-     */
-    @Override
-    public MessagePipeHandle passHandle() {
-        return mRouter.passHandle();
-    }
-
-    /**
-     * @see MessageReceiver#accept(Message)
-     */
-    @Override
-    public boolean accept(Message message) {
-        return mRouter.accept(message);
-    }
-
-    /**
-     * @see MessageReceiverWithResponder#acceptWithResponder(Message, MessageReceiver)
-     */
-    @Override
-    public boolean acceptWithResponder(Message message, MessageReceiver responder) {
-        return mRouter.acceptWithResponder(message, responder);
-
-    }
-
-    /**
-     * @see Router#start()
-     */
-    @Override
-    public void start() {
-        mRouter.start();
-    }
-
-    /**
-     * @see Router#setErrorHandler(ConnectionErrorHandler)
-     */
-    @Override
-    public void setErrorHandler(ConnectionErrorHandler errorHandler) {
-        mRouter.setErrorHandler(errorHandler);
-    }
-
-    /**
-     * @see java.io.Closeable#close()
-     */
-    @Override
-    public void close() {
-        mRouter.close();
-        mClosed = true;
-    }
-
-    /**
-     * @see Object#finalize()
-     */
-    @Override
-    protected void finalize() throws Throwable {
-        if (!mClosed) {
-            mExecutor.execute(new Runnable() {
-
-                @Override
-                public void run() {
-                    close();
-                }
-            });
-            throw new IllegalStateException("Warning: Router objects should be explicitly closed " +
-                    "when no longer required otherwise you may leak handles.");
-        }
-        super.finalize();
-    }
-}