Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   *  Licensed to the Apache Software Foundation (ASF) under one or more
   *  contributor license agreements.  See the NOTICE file distributed with
   *  this work for additional information regarding copyright ownership.
   *  The ASF licenses this file to You under the Apache License, Version 2.0
   *  (the "License"); you may not use this file except in compliance with
   *  the License.  You may obtain a copy of the License at
   *
   *      http://www.apache.org/licenses/LICENSE-2.0
  *
  *  Unless required by applicable law or agreed to in writing, software
  *  distributed under the License is distributed on an "AS IS" BASIS,
  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
 package org.apache.tomcat.websocket;
 
 import  java.nio.channels.AsynchronousSocketChannel;
 import  java.nio.channels.CompletionHandler;
Generally, just passes calls straight to the wrapped AsynchronousSocketChannel. In some cases exceptions may be swallowed to save them being swallowed by the calling code.
 
 public class AsyncChannelWrapperNonSecure implements AsyncChannelWrapper {
 
     private static final Future<VoidNOOP_FUTURE = new NoOpFuture();
 
     private final AsynchronousSocketChannel socketChannel;
 
             AsynchronousSocketChannel socketChannel) {
         this. = socketChannel;
     }
 
     @Override
     public Future<Integerread(ByteBuffer dst) {
         return .read(dst);
     }
 
     @Override
     public <B,A extends B> void read(ByteBuffer dst, A attachment,
             CompletionHandler<Integer,B> handler) {
         .read(dstattachmenthandler);
     }
 
     @Override
     public Future<Integerwrite(ByteBuffer src) {
         return .write(src);
     }
 
     @Override
     public <B,A extends B> void write(ByteBuffer[] srcsint offsetint length,
             long timeoutTimeUnit unit, A attachment,
             CompletionHandler<Long,B> handler) {
         .write(
                 srcsoffsetlengthtimeoutunitattachmenthandler);
     }
 
     @Override
     public void close() {
         try {
             .close();
         } catch (IOException e) {
             // Ignore
         }
     }
 
     @Override
     public Future<Voidhandshake() {
         return ;
     }
 
 
     private static final class NoOpFuture implements Future<Void> {
 
         @Override
         public boolean cancel(boolean mayInterruptIfRunning) {
             return false;
         }
 
         @Override
         public boolean isCancelled() {
             return false;
         }
 
         @Override
         public boolean isDone() {
             return true;
         }
 
        @Override
        public Void get() throws InterruptedExceptionExecutionException {
            return null;
        }
        @Override
        public Void get(long timeoutTimeUnit unit)
                throws InterruptedExceptionExecutionException,
                TimeoutException {
            return null;
        }
    }
New to GrepCode? Check out our FAQ X