Uses of Class
io.vertx.mutiny.core.parsetools.RecordParser
Packages that use RecordParser
-
Uses of RecordParser in io.vertx.mutiny.core.parsetools
Fields in io.vertx.mutiny.core.parsetools with type parameters of type RecordParserMethods in io.vertx.mutiny.core.parsetools that return RecordParserModifier and TypeMethodDescriptionRecordParser.endHandler(Runnable endHandler) RecordParser.exceptionHandler(Consumer<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(io.vertx.core.buffer.Buffer delim) Create a newRecordParserinstance, initially in delimited mode, and where the delimiter can be represented by theBufferdelim.static RecordParserRecordParser.newDelimited(io.vertx.core.buffer.Buffer delim, ReadStream<io.vertx.core.buffer.Buffer> stream) LikenewDelimited(Buffer)but wraps thestream.static RecordParserRecordParser.newDelimited(io.vertx.core.buffer.Buffer delim, Flow.Publisher<io.vertx.core.buffer.Buffer> stream) LikenewDelimited(Buffer)but wraps thestream.static RecordParserRecordParser.newDelimited(io.vertx.core.buffer.Buffer delim, Consumer<io.vertx.core.buffer.Buffer> output) LikenewDelimited(Buffer)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 String delim endcoded in latin-1 .static RecordParserRecordParser.newDelimited(String delim, ReadStream<io.vertx.core.buffer.Buffer> stream) LikenewDelimited(String)but wraps thestream.static RecordParserRecordParser.newDelimited(String delim, Flow.Publisher<io.vertx.core.buffer.Buffer> stream) LikenewDelimited(String)but wraps thestream.static RecordParserRecordParser.newDelimited(String delim, Consumer<io.vertx.core.buffer.Buffer> output) LikenewDelimited(String)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 RecordParserRecordParser.newFixed(int size, ReadStream<io.vertx.core.buffer.Buffer> stream) LikenewFixed(int)but wraps thestream.static RecordParserRecordParser.newFixed(int size, Flow.Publisher<io.vertx.core.buffer.Buffer> stream) LikenewFixed(int)but wraps thestream.static RecordParserLikenewFixed(int)but set theoutputthat will receive whole records which have been parsed.static RecordParserRecordParser.newInstance(io.vertx.core.parsetools.RecordParser delegate) Creates a new instance of theRecordParser.RecordParser.pause()RecordParser.pipeToAndForget(WriteStream<io.vertx.core.buffer.Buffer> arg0) Pipe thisReadStreamto theWriteStream.RecordParser.resume()