private void feed() throws java.io.IOException; } org/codehaus/plexus/util/cli/StreamPumper.class package org.codehaus.plexus.util.cli; public synchronized class StreamPumper extends Thread { private java.io.BufferedReader in; private StreamConsumer consumer; private java.io.PrintWriter out; private static final int SIZE = 1024; boolean done; public void StreamPumper(java.io.InputStream); public void StreamPumper(java.io.InputStream, StreamConsumer); public void StreamPumper(java.io.InputStream, java.io.PrintWriter);...

  }
  return count;
}

int TF_OperationOutputConsumers(TF_Output oper_out, TF_Input* consumers,
                                int max_consumers) {
  int count = 0;
  for (const auto* edge : oper_out.oper->node.out_edges()) {
    if (edge->src_output() == oper_out.index) {
      if (count < max_consumers) {
        consumers[count] = {ToOperation(edge->dst()), edge->dst_input()};
      }
      ++count;
    }

	return saveConfig(ctx, objectAPI, configFile, buf)
}

// getReplicationDiff returns un-replicated objects in a channel.
// If a non-nil channel is returned it must be consumed fully or
// the provided context must be canceled.
func getReplicationDiff(ctx context.Context, objAPI ObjectLayer, bucket string, opts madmin.ReplDiffOpts) (chan madmin.DiffInfo, error) {