Creates a reader thread. @param in input stream @param tb token builder @param cs charset @param pr process result @return result
(final InputStream in, final TokenBuilder tb, final Charset cs,
final ProcResult pr)
| 123 | * @return result |
| 124 | */ |
| 125 | private static Thread reader(final InputStream in, final TokenBuilder tb, final Charset cs, |
| 126 | final ProcResult pr) { |
| 127 | final InputStreamReader isr = new InputStreamReader(in, cs); |
| 128 | final BufferedReader br = new BufferedReader(isr); |
| 129 | return new Thread(() -> { |
| 130 | try { |
| 131 | for(int b; (b = br.read()) != -1;) tb.add(b); |
| 132 | } catch(final IOException ex) { |
| 133 | pr.exception = ex; |
| 134 | } |
| 135 | }); |
| 136 | } |
| 137 | } |