vertx / io.vertx.reactivex.core.parsetools / RecordParser / newFixed

newFixed

open static fun newFixed(size: Int): RecordParser

Create a new RecordParser instance, initially in fixed size mode, and where the record size is specified by the size parameter.

output Will receive whole records which have been parsed.

Parameters

size - the initial record size

Return

open static fun newFixed(size: Int, output: Handler<Buffer>): RecordParser

Like io.vertx.reactivex.core.parsetools.RecordParser#newFixed but set the output that will receive whole records which have been parsed.

Parameters

size - the initial record size

output - handler that will receive the output

Return

open static fun newFixed(size: Int, stream: ReadStream<Buffer>): RecordParser
open static fun newFixed(size: Int, stream: Flowable<Buffer>): RecordParser
open static fun newFixed(size: Int, stream: Observable<Buffer>): RecordParser

Like io.vertx.reactivex.core.parsetools.RecordParser#newFixed but wraps the stream. The stream handlers will be set/unset when the io.vertx.reactivex.core.parsetools.RecordParser#handler is set. The pause()/resume() operations are propagated to the stream.

Parameters

size - the initial record size

stream - the wrapped stream

Return