Changeset 416
- Timestamp:
- 07/16/07 13:37:45 (1 year ago)
- Files:
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
experiments/jruby-1/src/com/rubyeventmachine/EventableChannel.java
r415 r416 20 20 String myBinding; 21 21 Selector mySelector; 22 LinkedList OutboundQ;22 LinkedList<ByteBuffer> OutboundQ; 23 23 boolean bCloseScheduled; 24 24 … … 28 28 mySelector = sel; 29 29 bCloseScheduled = false; 30 OutboundQ = new LinkedList ();30 OutboundQ = new LinkedList<ByteBuffer>(); 31 31 32 32 sc.register(mySelector, SelectionKey.OP_READ, this); … … 51 51 public boolean writeOutboundData() throws ClosedChannelException { 52 52 while (!OutboundQ.isEmpty()) { 53 ByteBuffer b = (ByteBuffer)OutboundQ.getFirst();53 ByteBuffer b = OutboundQ.getFirst(); 54 54 try { 55 55 myChannel.write(b);
