1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.jboss.netty.channel.socket.oio;
17
18 import static org.jboss.netty.channel.Channels.*;
19
20 import java.io.OutputStream;
21 import java.io.PushbackInputStream;
22 import java.net.Socket;
23
24 import org.jboss.netty.channel.ChannelFactory;
25 import org.jboss.netty.channel.ChannelPipeline;
26 import org.jboss.netty.channel.ChannelSink;
27
28 class OioClientSocketChannel extends OioSocketChannel {
29
30 volatile PushbackInputStream in;
31 volatile OutputStream out;
32
33 OioClientSocketChannel(
34 ChannelFactory factory,
35 ChannelPipeline pipeline,
36 ChannelSink sink) {
37
38 super(null, factory, pipeline, sink, new Socket());
39
40 fireChannelOpen(this);
41 }
42
43 @Override
44 PushbackInputStream getInputStream() {
45 return in;
46 }
47
48 @Override
49 OutputStream getOutputStream() {
50 return out;
51 }
52 }