*
 * @author Colin Decker
 */
@NullUnmarked
public class ByteSinkTest extends IoTestCase {

  private final byte[] bytes = newPreFilledByteArray(10000);

  private TestByteSink sink;

  @Override
  protected void setUp() throws Exception {
    sink = new TestByteSink();
  }

  public void testOpenBufferedStream() throws IOException {
    OutputStream out = sink.openBufferedStream();
    assertTrue(sink.wasStreamOpened());

  private final ExecutorService finishToValueAndCloserExecutor = newSingleThreadExecutor();
  private volatile ValueAndCloser<?> valueAndCloser;

  @Override
  protected void tearDown() throws Exception {
    super.tearDown();
    assertWithMessage("finishToValueAndCloserExecutor was shut down")
        .that(shutdownAndAwaitTermination(finishToValueAndCloserExecutor, 10, SECONDS))

      Sets.difference(
              ImmutableSet.copyOf(QuantilesAlgorithm.values()),
              ImmutableSet.of(REFERENCE_ALGORITHM))
          .immutableCopy();

  private double[] dataset;

  @Override
  protected void setUp() {
    dataset = new double[DATASET_SIZE];
    for (int i = 0; i < DATASET_SIZE; i++) {
      dataset[i] = rng.nextDouble();
    }
  }

  public void testSingleQuantile_median() {

/**
 * Utility class for {@link SAXParser}.
 *
 * @author higa
 */
public abstract class SAXParserFactoryUtil {

    /**
     * Do not instantiate.
     */
    protected SAXParserFactoryUtil() {
    }

    /**
     * Creates a new instance of {@link SAXParserFactory}.
     *
     * @return A new instance of {@link SAXParserFactory}.
     */

public class GroovyEngineTest extends UnitFessTestCase {
    public GroovyEngine groovyEngine;

    @Override
    protected void setUp(TestInfo testInfo) throws Exception {
        super.setUp(testInfo);
        groovyEngine = new GroovyEngine();
    }

    @Override
    protected void tearDown(TestInfo testInfo) throws Exception {
        if (groovyEngine != null) {
            groovyEngine.close();
        }

 */
public abstract class ClassUtil {

    /**
     * Do not instantiate.
     */
    protected ClassUtil() {
    }

    /** Map from wrapper types to primitive types */
    protected static final Map<Class<?>, Class<?>> wrapperToPrimitiveMap = newHashMap();

    /** Map from primitive types to wrapper types */
    protected static final Map<Class<?>, Class<?>> primitiveToWrapperMap = newHashMap();

    private TestCorsHandlerFactory corsHandlerFactory;
    private TestHttpServletRequest mockRequest;
    private TestHttpServletResponse mockResponse;
    private TestFilterChain mockFilterChain;

    @Override
    protected void setUp(TestInfo testInfo) throws Exception {
        super.setUp(testInfo);
        corsFilter = new CorsFilter();
        corsHandlerFactory = new TestCorsHandlerFactory();
        // Initialize mocks

      state = STATE_READ_RESPONSE_HEADERS
    }
  }

  private abstract inner class AbstractSource(
    val url: HttpUrl,
  ) : Source {
    protected val timeout = ForwardingTimeout(socket.source.timeout())
    protected var closed: Boolean = false

    override fun timeout(): Timeout = timeout

    override fun read(
      sink: Buffer,
      byteCount: Long,
    ): Long =

    TestExecutor(MockExecutor mock) {
      super(mock);
    }

    @Override
    protected <T> Callable<T> wrapTask(Callable<T> callable) {
      return new WrappedCallable<T>(callable);
    }

    @Override
    protected Runnable wrapTask(Runnable command) {
      return new WrappedRunnable(command);
    }
  }

 * </ul>
 *
 * @since 14.0
 * @author Colin Decker
 */
@J2ktIncompatible
@GwtIncompatible
public abstract class ByteSink {

  /** Constructor for use by subclasses. */
  protected ByteSink() {}

  /**
   * Returns a {@link CharSink} view of this {@code ByteSink} that writes characters to this sink as
   * bytes encoded with the given {@link Charset charset}.
   */