Package | Description |
---|---|
io.vertx.reactivex.core.parsetools |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<RecordParser> |
RecordParser.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
RecordParser |
RecordParser.endHandler(Handler<Void> endHandler) |
RecordParser |
RecordParser.exceptionHandler(Handler<Throwable> handler) |
RecordParser |
RecordParser.fetch(long amount) |
RecordParser |
RecordParser.handler(Handler<Buffer> handler) |
RecordParser |
RecordParser.maxRecordSize(int size)
Set the maximum allowed size for a record when using the delimited mode.
|
static RecordParser |
RecordParser.newDelimited(Buffer delim)
Create a new
RecordParser instance, initially in delimited mode, and where the delimiter can be represented
by the Buffer delim. |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Flowable<Buffer> stream)
Like
newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.reactivex.core.buffer.Buffer>) but wraps the stream . |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Handler<Buffer> output)
Like
newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.reactivex.core.buffer.Buffer>) but set the output that will receive whole records
which have been parsed. |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
ReadStream<Buffer> stream)
Like
newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.reactivex.core.buffer.Buffer>) but wraps the stream . |
static RecordParser |
RecordParser.newDelimited(String delim)
Create a new
RecordParser instance, initially in delimited mode, and where the delimiter can be represented
by the String delim endcoded in latin-1 . |
static RecordParser |
RecordParser.newDelimited(String delim,
Flowable<Buffer> stream)
Like
newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.reactivex.core.buffer.Buffer>) but wraps the stream . |
static RecordParser |
RecordParser.newDelimited(String delim,
Handler<Buffer> output)
Like
newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.reactivex.core.buffer.Buffer>) but set the output that will receive whole records
which have been parsed. |
static RecordParser |
RecordParser.newDelimited(String delim,
ReadStream<Buffer> stream)
Like
newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.reactivex.core.buffer.Buffer>) but wraps the stream . |
static RecordParser |
RecordParser.newFixed(int size)
Create a new
RecordParser instance, initially in fixed size mode, and where the record size is specified
by the size parameter. |
static RecordParser |
RecordParser.newFixed(int size,
Flowable<Buffer> stream)
Like
newFixed(int) but wraps the stream . |
static RecordParser |
RecordParser.newFixed(int size,
Handler<Buffer> output)
Like
newFixed(int) but set the output that will receive whole records
which have been parsed. |
static RecordParser |
RecordParser.newFixed(int size,
ReadStream<Buffer> stream)
Like
newFixed(int) but wraps the stream . |
static RecordParser |
RecordParser.newInstance(RecordParser arg) |
RecordParser |
RecordParser.pause() |
RecordParser |
RecordParser.resume() |
Copyright © 2021 Eclipse. All rights reserved.