本文整理了Java中com.jcraft.jzlib.ZOutputStream.<init>()方法的一些代码示例，展示了ZOutputStream.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZOutputStream.<init>()方法的具体详情如下：
包路径：com.jcraft.jzlib.ZOutputStream
类名称：ZOutputStream
方法名：<init>

ZOutputStream.<init>介绍

暂无

代码示例

代码示例来源：origin: igniterealtime/Openfire

@Override
public void startCompression() {
  compressed = true;
  try {
    if (tlsStreamHandler == null) {
      ZOutputStream out = new ZOutputStream(
          ServerTrafficCounter.wrapOutputStream(socket.getOutputStream()),
          JZlib.Z_BEST_COMPRESSION);
      out.setFlushMode(JZlib.Z_PARTIAL_FLUSH);
      writer = new BufferedWriter(new OutputStreamWriter(out, StandardCharsets.UTF_8));
      xmlSerializer = new XMLSocketWriter(writer, this);
    }
    else {
      ZOutputStream out = new ZOutputStream(tlsStreamHandler.getOutputStream(), JZlib.Z_BEST_COMPRESSION);
      out.setFlushMode(JZlib.Z_PARTIAL_FLUSH);
      writer = new BufferedWriter(new OutputStreamWriter(out, StandardCharsets.UTF_8));
      xmlSerializer = new XMLSocketWriter(writer, this);
    }
  } catch (IOException e) {
    // TODO Would be nice to still be able to throw the exception and not catch it here
    Log.error("Error while starting compression", e);
    compressed = false;
  }
}

代码示例来源：origin: k9mail/k-9

private void enableCompression(Socket socket) throws IOException {
  InputStream inputStream = new InflaterInputStream(socket.getInputStream(), new Inflater(true));
  input = Okio.buffer(Okio.source(inputStream));
  ZOutputStream outputStream = new ZOutputStream(socket.getOutputStream(), JZlib.Z_BEST_SPEED, true);
  outputStream.setFlushMode(JZlib.Z_PARTIAL_FLUSH);
  output = Okio.buffer(Okio.sink(outputStream));
}

代码示例来源：origin: k9mail/k-9

private void enableCompression(Socket socket) throws IOException {
  InputStream inputStream = new InflaterInputStream(socket.getInputStream(), new Inflater(true));
  input = Okio.buffer(Okio.source(inputStream));
  ZOutputStream outputStream = new ZOutputStream(socket.getOutputStream(), JZlib.Z_BEST_SPEED, true);
  outputStream.setFlushMode(JZlib.Z_PARTIAL_FLUSH);
  output = Okio.buffer(Okio.sink(outputStream));
}

代码示例来源：origin: k9mail/k-9

private void enableCompression(Socket socket) throws IOException {
  InputStream inputStream = new InflaterInputStream(socket.getInputStream(), new Inflater(true));
  input = Okio.buffer(Okio.source(inputStream));
  ZOutputStream outputStream = new ZOutputStream(socket.getOutputStream(), JZlib.Z_BEST_SPEED, true);
  outputStream.setFlushMode(JZlib.Z_PARTIAL_FLUSH);
  output = Okio.buffer(Okio.sink(outputStream));
}

代码示例来源：origin: k9mail/k-9

private void enableCompression() throws IOException, MessagingException {
  try {
    executeSimpleCommand(Commands.COMPRESS_DEFLATE);
  } catch (NegativeImapResponseException e) {
    Timber.d(e, "Unable to negotiate compression: ");
    return;
  }
  try {
    InflaterInputStream input = new InflaterInputStream(socket.getInputStream(), new Inflater(true));
    ZOutputStream output = new ZOutputStream(socket.getOutputStream(), JZlib.Z_BEST_SPEED, true);
    output.setFlushMode(JZlib.Z_PARTIAL_FLUSH);
    setUpStreamsAndParser(input, output);
    if (K9MailLib.isDebug()) {
      Timber.i("Compression enabled for %s", getLogId());
    }
  } catch (IOException e) {
    close();
    Timber.e(e, "Error enabling compression");
  }
}

代码示例来源：origin: org.motechproject/motech-mobileforms-api

@RequestMapping(value = "/download", method = RequestMethod.POST)
@ResponseStatus(HttpStatus.OK)
public void downloadHandler(HttpServletRequest request, HttpServletResponse response) throws IOException {
  ZOutputStream zOutput = new ZOutputStream(response.getOutputStream(), JZlib.Z_BEST_COMPRESSION);
  DataInputStream dataInput = new DataInputStream(request.getInputStream());
  DataOutputStream dataOutput = new DataOutputStream(zOutput);
  try {
    readParameters(dataInput);
    byte action = readActionByte(dataInput);
    ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
    if (action == ACTION_DOWNLOAD_STUDY_LIST) {
      handleDownloadStudies(byteStream);
    } else if (action == ACTION_DOWNLOAD_USERS_AND_FORMS) {
      handleDownloadUsersAndForms(byteStream, dataInput);
    }
    dataOutput.writeByte(RESPONSE_SUCCESS);
    dataOutput.write(byteStream.toByteArray());
    log.info("successfully downloaded the xforms");
  } catch (Exception e) {
    dataOutput.writeByte(RESPONSE_ERROR);
    throw new SerializationFailedException(FAILED_TO_SERIALIZE_DATA, e);
  } finally {
    dataOutput.close();
    response.flushBuffer();
  }
}

代码示例来源：origin: org.igniterealtime.openfire/xmppserver

@Override
public void startCompression() {
  compressed = true;
  try {
    if (tlsStreamHandler == null) {
      ZOutputStream out = new ZOutputStream(
          ServerTrafficCounter.wrapOutputStream(socket.getOutputStream()),
          JZlib.Z_BEST_COMPRESSION);
      out.setFlushMode(JZlib.Z_PARTIAL_FLUSH);
      writer = new BufferedWriter(new OutputStreamWriter(out, StandardCharsets.UTF_8));
      xmlSerializer = new XMLSocketWriter(writer, this);
    }
    else {
      ZOutputStream out = new ZOutputStream(tlsStreamHandler.getOutputStream(), JZlib.Z_BEST_COMPRESSION);
      out.setFlushMode(JZlib.Z_PARTIAL_FLUSH);
      writer = new BufferedWriter(new OutputStreamWriter(out, StandardCharsets.UTF_8));
      xmlSerializer = new XMLSocketWriter(writer, this);
    }
  } catch (IOException e) {
    // TODO Would be nice to still be able to throw the exception and not catch it here
    Log.error("Error while starting compression", e);
    compressed = false;
  }
}

代码示例来源：origin: google/sagetv

zout = new com.jcraft.jzlib.ZOutputStream(clientSocket.socket().getOutputStream(), 5/*halfway between best speed & best compression*/, true);
zout.setFlushMode(com.jcraft.jzlib.JZlib.Z_SYNC_FLUSH);

代码示例来源：origin: aurorafeint/jruby-memcached

if (getFlags() == COMPRESS_FLAG) {
  ByteArrayOutputStream out2 = new ByteArrayOutputStream();
  zout = new ZOutputStream(out2, JZlib.Z_DEFAULT_COMPRESSION);
  zout.write(out1.toByteArray());
  zout.flush();

代码示例来源：origin: org.motechproject/motech-mobileforms-api

@RequestMapping(value = "/upload", method = RequestMethod.POST)
@ResponseStatus(HttpStatus.OK)
public void uploadHandler(HttpServletRequest request, HttpServletResponse response) throws IOException {
  ZOutputStream zOutput = new ZOutputStream(response.getOutputStream(), JZlib.Z_BEST_COMPRESSION);
  DataInputStream dataInput = new DataInputStream(request.getInputStream());
  DataOutputStream dataOutput = new DataOutputStream(zOutput);

代码示例来源：origin: google/sagetv

zout = new com.jcraft.jzlib.ZOutputStream(clientSocket.socket().getOutputStream(), 5/*halfway between best speed & best compression*/, true);
zout.setFlushMode(com.jcraft.jzlib.JZlib.Z_SYNC_FLUSH);