MCPcopy Create free account
hub / github.com/BaseXdb/basex / reader

Method reader

basex-core/src/main/java/org/basex/query/func/proc/ProcFn.java:125–136  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

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}

Callers 1

execMethod · 0.95

Calls 2

readMethod · 0.65
addMethod · 0.65

Tested by

no test coverage detected