Uses of Class
io.vertx.rxjava3.core.parsetools.RecordParser
Packages that use RecordParser
-
Uses of RecordParser in io.vertx.rxjava3.core.parsetools
Fields in io.vertx.rxjava3.core.parsetools with type parameters of type RecordParserModifier and TypeFieldDescriptionstatic final io.vertx.lang.rx.TypeArg<RecordParser> RecordParser.__TYPE_ARGMethods in io.vertx.rxjava3.core.parsetools that return RecordParserModifier and TypeMethodDescriptionRecordParser.endHandler(Handler<Void> endHandler) RecordParser.exceptionHandler(Handler<Throwable> handler) RecordParser.fetch(long amount) RecordParser.maxRecordSize(int size) Set the maximum allowed size for a record when using the delimited mode.static RecordParserRecordParser.newDelimited(Buffer delim) Create a newRecordParserinstance, initially in delimited mode, and where the delimiter can be represented by theBufferdelim.static RecordParserRecordParser.newDelimited(Buffer delim, Flowable<Buffer> stream) LikeRecordParser.newDelimited(String, Handler)but wraps thestream.static RecordParserRecordParser.newDelimited(Buffer delim, Handler<Buffer> output) LikeRecordParser.newDelimited(String, Handler)but set theoutputthat will receive whole records which have been parsed.static RecordParserRecordParser.newDelimited(String delim) Create a newRecordParserinstance, initially in delimited mode, and where the delimiter can be represented by the Stringdelim endcoded in latin-1 .static RecordParserRecordParser.newDelimited(String delim, Flowable<Buffer> stream) LikeRecordParser.newDelimited(String, Handler)but wraps thestream.static RecordParserRecordParser.newDelimited(String delim, Handler<Buffer> output) LikeRecordParser.newDelimited(String, Handler)but set theoutputthat will receive whole records which have been parsed.static RecordParserRecordParser.newFixed(int size) Create a newRecordParserinstance, initially in fixed size mode, and where the record size is specified by thesizeparameter.static RecordParserLikeRecordParser.newFixed(int)but wraps thestream.static RecordParserLikeRecordParser.newFixed(int)but set theoutputthat will receive whole records which have been parsed.static RecordParserRecordParser.newInstance(RecordParser arg) RecordParser.pause()RecordParser.resume()