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

newDelimited

open static fun newDelimited(delim: String, output: Handler<Buffer>): RecordParser

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

Parameters

delim - the initial delimiter string

output - handler that will receive the output

Return

open static fun newDelimited(delim: String, stream: ReadStream<Buffer>): RecordParser
open static fun newDelimited(delim: String, stream: Flowable<Buffer>): RecordParser
open static fun newDelimited(delim: String, stream: Observable<Buffer>): RecordParser

Like io.vertx.reactivex.core.parsetools.RecordParser#newDelimited 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

delim - the initial delimiter string

stream - the wrapped stream

Return

open static fun newDelimited(delim: String): RecordParser

Create a new RecordParser instance, initially in delimited mode, and where the delimiter can be represented by the String delim endcoded in latin-1 . Don't use this if your String contains other than latin-1 characters.

output Will receive whole records which have been parsed.

Parameters

delim - the initial delimiter string

Return

open static fun newDelimited(delim: Buffer): RecordParser

Create a new RecordParser instance, initially in delimited mode, and where the delimiter can be represented by the Buffer delim.

Parameters

delim - the initial delimiter buffer

Return

open static fun newDelimited(delim: Buffer, output: Handler<Buffer>): RecordParser

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

Parameters

delim - the initial delimiter buffer

output - handler that will receive the output

Return

open static fun newDelimited(delim: Buffer, stream: ReadStream<Buffer>): RecordParser
open static fun newDelimited(delim: Buffer, stream: Flowable<Buffer>): RecordParser
open static fun newDelimited(delim: Buffer, stream: Observable<Buffer>): RecordParser

Like io.vertx.reactivex.core.parsetools.RecordParser#newDelimited 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

delim - the initial delimiter buffer

stream - the wrapped stream

Return