Home
last modified time | relevance | path

Searched refs:deflater (Results 1 – 1 of 1) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DPerMessageDeflate.java54 private final Deflater deflater = new Deflater(Deflater.DEFAULT_COMPRESSION, true); field in PerMessageDeflate
338 deflater.setInput(uncompressedPayload.array(), in sendMessagePart()
348 int written = deflater.deflate(compressedPayload.array(), in sendMessagePart()
353 … if (!uncompressedPart.isFin() && compressedPayload.hasRemaining() && deflater.needsInput()) { in sendMessagePart()
372 boolean needsInput = deflater.needsInput(); in sendMessagePart()
404 … int eomBufferWritten = deflater.deflate(EOM_BUFFER, 0, EOM_BUFFER.length, Deflater.SYNC_FLUSH); in sendMessagePart()
454 deflater.reset(); in startNewMessage()
474 deflater.end(); in close()