Class AsyncVcfWriter

src/main/java/com/rtg/vcf/AsyncVcfWriter.java:44–86

Adaptor that allows asynchronous writing of our VcfRecord objects.

 * Adaptor that allows asynchronous writing of our VcfRecord objects.
 */
public class AsyncVcfWriter extends AbstractAsyncWriter<VcfRecord> implements VcfWriter {

  private static final int BUFFER_SIZE = GlobalFlags.getIntegerValue(ToolsGlobalFlags.VCF_ASYNC_BUFFER_SIZE);

  private final VcfWriter mWriter;

  /**
   * Constructor
   * @param w the inner VcfWriter
   */
  public AsyncVcfWriter(VcfWriter w) {
    super(BUFFER_SIZE);
    mWriter = w;
  }

  @Override
  public VcfHeader getHeader() {
    return mWriter.getHeader();
  }

  @Override
  protected String getThreadNamePrefix() {
    return "VcfWriter";
  }

  @Override
  protected void synchronouslyWrite(VcfRecord record) {
    try {
      mWriter.write(record);
    } catch (IOException e) {
      throw new RuntimeIOException(e);
    }
  }

  @Override
  protected void synchronouslyClose() {
    try {
      mWriter.close();
    } catch (IOException e) {
      throw new RuntimeIOException(e);
    }
  }
}