kevinweil

Verifying my Blockstack ID is secured with the address 15S9Wded5wQfvppmoBMT4Yd2Dj5n9XMVsY https://explorer.blockstack.org/address/15S9Wded5wQfvppmoBMT4Yd2Dj5n9XMVsY

kevinweil

package net.abhinavsarkar.util;

import java.util.Iterator;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;

kevinweil

import com.google.protobuf.Message
import java.io.{BufferedReader, BufferedInputStream, DataInputStream, File, FileInputStream, InputStream, InputStreamReader}
import java.util.zip.GZIPInputStream
import scala.reflect.Manifest
 
class ProtobufFileScanner[M <: Message](implicit man: Manifest[M]) {
  var file: File = null
  var bufferedIn: BufferedInputStream = null
 
  // ensure we're not at EOF