本文整理了Java中org.glassfish.grizzly.streams.Output
类的一些代码示例,展示了Output
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Output
类的具体详情如下:
包路径:org.glassfish.grizzly.streams.Output
类名称:Output
暂无
代码示例来源:origin: javaee/grizzly
@Override
public void writeInt(final int data) throws IOException {
if (isOutputBuffered) {
output.ensureBufferCapacity(4);
output.getBuffer().putInt(data);
} else {
output.write((byte) ((data >>> 24) & 0xFF));
output.write((byte) ((data >>> 16) & 0xFF));
output.write((byte) ((data >>> 8) & 0xFF));
output.write((byte) ((data) & 0xFF));
}
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-websockets-server
/**
* Cause the overflow handler to be called even if buffer is not full.
*/
@Override
public GrizzlyFuture<Integer> flush(CompletionHandler<Integer> completionHandler)
throws IOException {
return output.flush(completionHandler);
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-websockets-server
/** Create a new ByteBufferWriter. An instance maintains a current buffer
* for use in writing. Whenever the current buffer is insufficient to hold
* the required data, the BufferHandler is called, and the result of the
* handler is the new current buffer. The handler is responsible for
* the disposition of the contents of the old buffer.
*/
protected AbstractStreamWriter(final Connection connection,
Output streamOutput) {
this.connection = connection;
this.output = streamOutput;
this.isOutputBuffered = streamOutput.isBuffered();
}
代码示例来源:origin: javaee/grizzly
underlyingOutput.write(outputBuffer);
transformer.release(attributeStorage);
} else if (status == Status.INCOMPLETE) {
return underlyingOutput.flush(completionHandler);
代码示例来源:origin: org.glassfish.grizzly/grizzly-websockets-server
/**
* {@inheritDoc}
*/
@Override
public void writeBooleanArray(final boolean[] data) throws IOException {
for(int i=0; i<data.length; i++) {
output.write((byte) (data[i] ? 1 : 0));
}
}
代码示例来源:origin: javaee/grizzly
/**
* {@inheritDoc}
*/
@Override
public GrizzlyFuture<Integer> close(
CompletionHandler<Integer> completionHandler) throws IOException {
if (!isClosed.getAndSet(true)) {
return output.close(completionHandler);
}
return ReadyFutureImpl.create(0);
}
代码示例来源:origin: javaee/grizzly
underlyingOutput.write(outputBuffer);
transformer.release(attributeStorage);
} else if (status == Status.INCOMPLETE) {
return underlyingOutput.flush(completionHandler);
代码示例来源:origin: javaee/grizzly
/**
* {@inheritDoc}
*/
@Override
public void writeBuffer(Buffer b) throws IOException {
output.write(b);
}
代码示例来源:origin: javaee/grizzly
/**
* {@inheritDoc}
*/
@Override
public GrizzlyFuture<Integer> close(
CompletionHandler<Integer> completionHandler) throws IOException {
if (!isClosed.getAndSet(true)) {
return output.close(completionHandler);
}
return ReadyFutureImpl.create(0);
}
代码示例来源:origin: javaee/grizzly
@Override
public void writeInt(final int data) throws IOException {
if (isOutputBuffered) {
output.ensureBufferCapacity(4);
output.getBuffer().putInt(data);
} else {
output.write((byte) ((data >>> 24) & 0xFF));
output.write((byte) ((data >>> 16) & 0xFF));
output.write((byte) ((data >>> 8) & 0xFF));
output.write((byte) ((data) & 0xFF));
}
}
代码示例来源:origin: org.mule.glassfish.grizzly/grizzly-framework
underlyingOutput.write(outputBuffer);
transformer.release(attributeStorage);
} else if (status == Status.INCOMPLETE) {
return underlyingOutput.flush(completionHandler);
代码示例来源:origin: javaee/grizzly
/**
* {@inheritDoc}
*/
@Override
public void writeBuffer(Buffer b) throws IOException {
output.write(b);
}
代码示例来源:origin: javaee/grizzly
/**
* {@inheritDoc}
*/
@Override
public GrizzlyFuture<Integer> close(
CompletionHandler<Integer> completionHandler) throws IOException {
if (!isClosed.getAndSet(true)) {
return output.close(completionHandler);
}
return ReadyFutureImpl.create(0);
}
代码示例来源:origin: javaee/grizzly
/** Create a new ByteBufferWriter. An instance maintains a current buffer
* for use in writing. Whenever the current buffer is insufficient to hold
* the required data, the BufferHandler is called, and the result of the
* handler is the new current buffer. The handler is responsible for
* the disposition of the contents of the old buffer.
*/
protected AbstractStreamWriter(final Connection connection,
Output streamOutput) {
this.connection = connection;
this.output = streamOutput;
this.isOutputBuffered = streamOutput.isBuffered();
}
代码示例来源:origin: javaee/grizzly
/**
* Cause the overflow handler to be called even if buffer is not full.
*/
@Override
public GrizzlyFuture<Integer> flush(CompletionHandler<Integer> completionHandler)
throws IOException {
return output.flush(completionHandler);
}
代码示例来源:origin: javaee/grizzly
@Override
public void writeInt(final int data) throws IOException {
if (isOutputBuffered) {
output.ensureBufferCapacity(4);
output.getBuffer().putInt(data);
} else {
output.write((byte) ((data >>> 24) & 0xFF));
output.write((byte) ((data >>> 16) & 0xFF));
output.write((byte) ((data >>> 8) & 0xFF));
output.write((byte) ((data) & 0xFF));
}
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-http-server-core
underlyingOutput.write(outputBuffer);
transformer.release(attributeStorage);
} else if (status == Status.INCOMPLETE) {
return underlyingOutput.flush(completionHandler);
代码示例来源:origin: javaee/grizzly
/**
* {@inheritDoc}
*/
@Override
public void writeBooleanArray(final boolean[] data) throws IOException {
for(int i=0; i<data.length; i++) {
output.write((byte) (data[i] ? 1 : 0));
}
}
代码示例来源:origin: org.glassfish.grizzly/grizzly-websockets-server
/**
* {@inheritDoc}
*/
@Override
public GrizzlyFuture<Integer> close(
CompletionHandler<Integer> completionHandler) throws IOException {
if (!isClosed.getAndSet(true)) {
return output.close(completionHandler);
}
return ReadyFutureImpl.create(0);
}
代码示例来源:origin: javaee/grizzly
/** Create a new ByteBufferWriter. An instance maintains a current buffer
* for use in writing. Whenever the current buffer is insufficient to hold
* the required data, the BufferHandler is called, and the result of the
* handler is the new current buffer. The handler is responsible for
* the disposition of the contents of the old buffer.
*/
protected AbstractStreamWriter(final Connection connection,
Output streamOutput) {
this.connection = connection;
this.output = streamOutput;
this.isOutputBuffered = streamOutput.isBuffered();
}
内容来源于网络,如有侵权,请联系作者删除!