Java 类com.fasterxml.jackson.core.json.async.NonBlockingJsonParser 实例源码

@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;
}