Method run

src/rnabloom/io/FastaWriterWorker.java:42–68

()

    }

    @Override
    public void run() {
        try {
            while(true) {
                String seq = inputQueue.poll();

                if (seq == null) {
                    if (terminateWhenInputExhausts) {
                        break;
                    }
                    sleep(100);
                    continue;
                }
                
                String header = seqPrefix + ++numSeq + " l=" + Integer.toString(seq.length());

                writer.write(header, seq);
            }

            successful = true;

        } catch (Exception ex) {
            System.out.println(ex.getMessage());
            exception = ex;
            successful = false;
        }
    }

    public void terminateWhenInputExhausts() {
        terminateWhenInputExhausts = true;