1 files changed, 37 insertions, 0 deletions
diff --git a/AndroidAsync/src/com/koushikdutta/async/SocketChannelWrapper.java b/AndroidAsync/src/com/koushikdutta/async/SocketChannelWrapper.java
new file mode 100644
index 0000000..47feef6
--- /dev/null
+++ b/AndroidAsync/src/com/koushikdutta/async/SocketChannelWrapper.java
@@ -0,0 +1,37 @@
+package com.koushikdutta.async;
+
+import java.io.IOException;
+import java.nio.ByteBuffer;
+import java.nio.channels.ClosedChannelException;
+import java.nio.channels.SelectionKey;
+import java.nio.channels.Selector;
+import java.nio.channels.SocketChannel;
+
+class SocketChannelWrapper extends ChannelWrapper {
+    SocketChannel mChannel;
+
+    SocketChannelWrapper(SocketChannel channel) throws IOException {
+        super(channel);
+        mChannel = channel;
+    }
+    @Override
+    public int read(ByteBuffer buffer) throws IOException {
+        return mChannel.read(buffer);
+    }
+    @Override
+    public boolean isConnected() {
+        return mChannel.isConnected();
+    }
+    @Override
+    public int write(ByteBuffer src) throws IOException {
+        return mChannel.write(src);
+    }
+    @Override
+    public int write(ByteBuffer[] src) throws IOException {
+        return (int)mChannel.write(src);
+    }
+    @Override
+    public SelectionKey register(Selector sel) throws ClosedChannelException {
+        return register(sel, SelectionKey.OP_CONNECT);
+    }
+}