@Override public JsonParser createNonBlockingByteArrayParser(ObjectReadContext readCtxt) throws IOException { IOContext ioCtxt = _createContext(null, false); ByteQuadsCanonicalizer can = _byteSymbolCanonicalizer.makeChild(_factoryFeatures); return new NonBlockingJsonParser(readCtxt, ioCtxt, readCtxt.getParserFeatures(_parserFeatures), can); }
@Override public NonBlockingParser createNonBlockingParser(SurfingContext context) { try { NonBlockingJsonParser jp = (NonBlockingJsonParser) factory.createNonBlockingByteArrayParser(); return new JacksonNonblockingParser(jp, context); } catch (IOException e) { context.getConfig().getErrorHandlingStrategy().handleParsingException(e); } return null; }
public AsyncJsonParser(JsonFactory jsonFactory, Consumer<JsonNode> onNodeDone) throws IOException { this.onNodeDone = onNodeDone; this.parser = (NonBlockingJsonParser) jsonFactory.createNonBlockingByteArrayParser(); }
JacksonNonblockingParser(NonBlockingJsonParser jsonParser, SurfingContext context) { super(jsonParser, context); this.nonBlockingJsonParser = jsonParser; }