import okhttp3.Response;
import okio.BufferedSink;

public final class PostStreaming {
  public static final MediaType MEDIA_TYPE_MARKDOWN
      = MediaType.get("text/x-markdown; charset=utf-8");

  private final OkHttpClient client = new OkHttpClient();

  public void run() throws Exception {
    RequestBody requestBody = new RequestBody() {
      @Override public MediaType contentType() {
        return MEDIA_TYPE_MARKDOWN;

  public long getCount() {
    return count;
  }

  @Override
  public void write(byte[] b, int off, int len) throws IOException {
    out.write(b, off, len);
    count += len;
  }

  @Override
  public void write(int b) throws IOException {
    out.write(b);
    count++;
  }

  // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior:

/**
 * Exception that wraps {@link IndexOutOfBoundsException}.
 *
 * @author wyukawa
 */
public class ClIndexOutOfBoundsException extends IndexOutOfBoundsException {

    private static final long serialVersionUID = -824874776607593608L;

    /**
     * Creates a {@link ClIndexOutOfBoundsException}.
     */
    public ClIndexOutOfBoundsException() {
        super();
    }

    /**

/**
 * Test class for Referral
 */
public class ReferralTest {

    private Referral referral;
    private byte[] testBuffer;

    @BeforeEach
    public void setUp() {
        referral = new Referral();
        testBuffer = new byte[512];
    }

    // Version 3 Referral Tests

    @Test
    public void testDecodeVersion3WithoutNameList() {
        // Prepare test data

 *
 * @author Pete Gillin
 * @author Kevin Bourrillion
 * @since 20.0
 */
@J2ktIncompatible
@GwtIncompatible
public final class StatsAccumulator {
  /** Creates a new accumulator. */
  public StatsAccumulator() {}

  // These fields must satisfy the requirements of Stats' constructor as well as those of the stat
  // methods of this class.
  private long count = 0;

  ImmutableCollection() {}

  /** Returns an unmodifiable iterator across the elements in this collection. */
  @Override
  public abstract UnmodifiableIterator<E> iterator();

  @Override
  public Spliterator<E> spliterator() {
    return Spliterators.spliterator(this, SPLITERATOR_CHARACTERISTICS);
  }

  private static final Object[] EMPTY_ARRAY = {};

  @Override

 *
 * @author Kurt Alfred Kluever
 * @since 11.0
 */
@GwtCompatible
public final class Queues {
  private Queues() {}

  // ArrayBlockingQueue

  /**
   * Creates an empty {@code ArrayBlockingQueue} with the given (fixed) capacity and nonfair access
   * policy.
   */
  @J2ktIncompatible
  @GwtIncompatible // ArrayBlockingQueue
  public static <E> ArrayBlockingQueue<E> newArrayBlockingQueue(int capacity) {

/**
 * The search form for Data Config.
 */
public class SearchForm {

    /**
     * Default constructor for SearchForm.
     */
    public SearchForm() {
    }

    /**
     * The name field for searching data configurations.
     */
    public String name;

    /**
     * The handler name field for searching data configurations.
     */
    public String handlerName;

    /**

 * WeakHashMap} uses {@link Object#equals}.
 *
 * @author Bob Lee
 * @author Charles Fry
 * @author Kevin Bourrillion
 * @since 2.0
 */
@J2ktIncompatible
@GwtCompatible
public final class MapMaker {
  private static final int DEFAULT_INITIAL_CAPACITY = 16;
  private static final int DEFAULT_CONCURRENCY_LEVEL = 4;

  static final int UNSET_INT = -1;

        project.setExecutionRoot(true);
        return project;
    }

    @Override
    public MavenProject buildStandaloneSuperProject(ArtifactRepository localRepository)
            throws ProjectBuildingException {
        return buildStandaloneSuperProject(localRepository, null);
    }

    @Override
    public MavenProject buildStandaloneSuperProject(ArtifactRepository localRepository, ProfileManager profileManager)