public CharSink createSink() throws IOException {
        return factory.createSink().asCharSink(Charsets.UTF_8);
      }

      @Override
      public String getSinkContents() throws IOException {
        return new String(factory.getSinkContents(), Charsets.UTF_8);
      }

      @Override
      public String getExpected(String data) {
        /*

    sink.writeLines(lines.stream(), separator);

    assertContainsExpectedLines(separator);
  }

  private void assertContainsExpectedString() throws IOException {
    assertEquals(expected, factory.getSinkContents());
  }

  private void assertContainsExpectedLines(String separator) throws IOException {
    String expected = expectedLines.isEmpty() ? "" : Joiner.on(separator).join(expectedLines);
    if (!lines.isEmpty()) {

      public CharSink createSink() throws IOException {
        return factory.createSink().asCharSink(Charsets.UTF_8);
      }

      @Override
      public String getSinkContents() throws IOException {
        return new String(factory.getSinkContents(), Charsets.UTF_8);
      }

      @Override
      public String getExpected(String data) {
        /*

    sink.writeLines(lines, separator);

    assertContainsExpectedLines(separator);
  }

  private void assertContainsExpectedString() throws IOException {
    assertEquals(expected, factory.getSinkContents());
  }

  private void assertContainsExpectedLines(String separator) throws IOException {
    String expected = expectedLines.isEmpty() ? "" : Joiner.on(separator).join(expectedLines);
    if (!lines.isEmpty()) {

  public interface SinkFactory<S, T> extends SourceSinkFactory<S, T> {

    /** Creates a new sink. */
    S createSink() throws IOException;

    /** Gets the current content of the created sink. */
    T getSinkContents() throws IOException;
  }

  /** Factory for {@link ByteSource} instances. */
  public interface ByteSourceFactory extends SourceFactory<ByteSource, byte[]> {}

  /** Factory for {@link ByteSink} instances. */

    sink.writeFrom(new ByteArrayInputStream(data));

    assertContainsExpectedBytes();
  }

  private void assertContainsExpectedBytes() throws IOException {
    assertArrayEquals(expected, factory.getSinkContents());
  }

    sink.writeFrom(new ByteArrayInputStream(data));

    assertContainsExpectedBytes();
  }

  private void assertContainsExpectedBytes() throws IOException {
    assertArrayEquals(expected, factory.getSinkContents());
  }

  public interface SinkFactory<S, T> extends SourceSinkFactory<S, T> {

    /** Creates a new sink. */
    S createSink() throws IOException;

    /** Gets the current content of the created sink. */
    T getSinkContents() throws IOException;
  }

  /** Factory for {@link ByteSource} instances. */
  public interface ByteSourceFactory extends SourceFactory<ByteSource, byte[]> {}

  /** Factory for {@link ByteSink} instances. */