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();
}