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
29
30
31
32
33
34
35
36 class OioClientSocketChannel extends OioSocketChannel {
37
38 volatile PushbackInputStream in;
39 volatile OutputStream out;
40
41 OioClientSocketChannel(
42 ChannelFactory factory,
43 ChannelPipeline pipeline,
44 ChannelSink sink) {
45
46 super(null, factory, pipeline, sink, new Socket());
47
48 fireChannelOpen(this);
49 }
50
51 @Override
52 PushbackInputStream getInputStream() {
53 return in;
54 }
55
56 @Override
57 OutputStream getOutputStream() {
58 return out;
59 }
60 }