Index: components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/DataPipe.java |
diff --git a/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/DataPipe.java b/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/DataPipe.java |
deleted file mode 100644 |
index c36319a897c3d8c2d6392642188de97893118c4b..0000000000000000000000000000000000000000 |
--- a/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/DataPipe.java |
+++ /dev/null |
@@ -1,79 +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.components.devtools_bridge; |
- |
-import java.nio.ByteBuffer; |
- |
-/** |
- * Represents a pair of connected AbstractDataChannel's. Sends to one channel |
- * come to another and vice versa. |
- */ |
-public class DataPipe { |
- private final SignalingThreadMock mSignalingThread = new SignalingThreadMock(); |
- |
- private final PairedDataChannel mDC0 = new PairedDataChannel(); |
- private final PairedDataChannel mDC1 = new PairedDataChannel(); |
- |
- public void connect() { |
- mDC0.setPair(mDC1); |
- mDC1.setPair(mDC0); |
- mDC0.open(); |
- mDC1.open(); |
- } |
- |
- public void disconnect() { |
- mDC0.setPair(null); |
- mDC1.setPair(null); |
- mDC0.close(); |
- mDC1.close(); |
- } |
- |
- public AbstractDataChannel dataChannel(int index) { |
- switch (index) { |
- case 0: |
- return mDC0; |
- case 1: |
- return mDC1; |
- default: |
- throw new IllegalArgumentException("index"); |
- } |
- } |
- |
- public void dispose() { |
- mDC0.dispose(); |
- mDC1.dispose(); |
- mSignalingThread.dispose(); |
- } |
- |
- private class PairedDataChannel extends DataChannelMock { |
- private PairedDataChannel mPair; |
- |
- public PairedDataChannel() { |
- super(mSignalingThread); |
- } |
- |
- public void setPair(final PairedDataChannel pair) { |
- mSignalingThread.invoke(new Runnable() { |
- @Override |
- public void run() { |
- mPair = pair; |
- } |
- }); |
- } |
- |
- @Override |
- protected void sendOnSignalingThread(ByteBuffer message) { |
- assert message.remaining() > 0; |
- |
- if (mPair == null) return; |
- mPair.notifyMessageOnSignalingThread(message); |
- } |
- |
- @Override |
- protected void disposeSignalingThread() { |
- // Ignore. Will dispose in DataPipe.dispose. |
- } |
- } |
-} |