Java 类javax.servlet.http.WebConnection 实例源码

项目:sample.daytrader7    文件:PingUpgradeServlet.java   
@Override
public void init(final WebConnection wc) {
    Listener listener = null;
    try {
        listener = new Listener(wc);

    } catch (IOException e1) {
        // TODO Auto-generated catch block
        e1.printStackTrace();
    }

    try {

        if (Log.doTrace()) {
            Log.trace("PingUpgradeServlet$Handler.init() -- Initializing Handler");
        }

        // flush headers if any
        wc.getOutputStream().flush();
        wc.getInputStream().setReadListener(listener);

    } catch (IOException e) {
        throw new IllegalArgumentException(e);
    }
}
项目:Mastering-Java-EE-Development-with-WildFly    文件:SampleProtocolHandler.java   
@Override
public void init(WebConnection wc) {
    try (ServletInputStream input = wc.getInputStream(); ServletOutputStream output = wc.getOutputStream();) {
        output.write(("upgrade" + CRLF).getBytes());
        output.write(("received" + CRLF).getBytes());
        output.write("END".getBytes());
    } catch (IOException ex) {
    }
}
项目:JavaIncrementalParser    文件:MyProtocolHandler.java   
@Override
public void init(WebConnection wc) {
    try (ServletInputStream input = wc.getInputStream();
        ServletOutputStream output = wc.getOutputStream();) {
    } catch (IOException ex) {
    }
}
项目:haven-platform    文件:ImmediateCloseConnection.java   
@Override
public void init(WebConnection wc) {
    close(wc::getInputStream);
    close(wc::getOutputStream);
}
项目:sample.daytrader7    文件:PingUpgradeServlet.java   
private Listener(final WebConnection connection) throws IOException  {
    this.connection = connection;
    this.input = connection.getInputStream();
    this.output = connection.getOutputStream();
}