equal
deleted
inserted
replaced
65 private boolean ordered; |
65 private boolean ordered; |
66 private boolean resetEventCache; |
66 private boolean resetEventCache; |
67 private long firstNanos; |
67 private long firstNanos; |
68 |
68 |
69 public ChunkParser(RecordingInput input, boolean reuse) throws IOException { |
69 public ChunkParser(RecordingInput input, boolean reuse) throws IOException { |
70 this(new ChunkHeader(input), null, 500); |
70 this(new ChunkHeader(input), null, 100); |
71 this.reuse = reuse; |
71 this.reuse = reuse; |
72 } |
72 } |
73 |
73 |
74 public ChunkParser(ChunkParser previous) throws IOException { |
74 public ChunkParser(ChunkParser previous) throws IOException { |
75 this(new ChunkHeader(previous.input), previous, 500); |
75 this(new ChunkHeader(previous.input), previous, 100); |
76 } |
76 } |
77 |
77 |
78 private ChunkParser(ChunkHeader header, ChunkParser previous, long pollInterval) throws IOException { |
78 private ChunkParser(ChunkHeader header, ChunkParser previous, long pollInterval) throws IOException { |
79 this.input = header.getInput(); |
79 this.input = header.getInput(); |
80 this.chunkHeader = header; |
80 this.chunkHeader = header; |