Modifier and Type | Method and Description |
---|---|
Files.TailLinesNonBlockingBuilder |
backpressureStrategy(io.reactivex.BackpressureStrategy backpressureStrategy) |
io.reactivex.Flowable<String> |
build() |
Files.TailLinesNonBlockingBuilder |
charset(Charset charset)
The charset of the file.
|
Files.TailLinesNonBlockingBuilder |
charset(String charset)
The charset of the file.
|
Files.TailLinesNonBlockingBuilder |
chunkSize(int chunkSize)
Emissions from the tailed file will be no bigger than this.
|
Files.TailLinesNonBlockingBuilder |
modifier(WatchEvent.Modifier modifier) |
Files.TailLinesNonBlockingBuilder |
pollingInterval(long pollingInterval,
TimeUnit unit) |
Files.TailLinesNonBlockingBuilder |
pollingInterval(long pollingInterval,
TimeUnit unit,
io.reactivex.Scheduler scheduler) |
Files.TailLinesNonBlockingBuilder |
startPosition(long startPosition)
The startPosition in bytes in the file to commence the tail from.
|
Files.TailLinesNonBlockingBuilder |
utf8() |
public Files.TailLinesNonBlockingBuilder pollingInterval(long pollingInterval, TimeUnit unit, io.reactivex.Scheduler scheduler)
public Files.TailLinesNonBlockingBuilder pollingInterval(long pollingInterval, TimeUnit unit)
public Files.TailLinesNonBlockingBuilder startPosition(long startPosition)
startPosition
- start positionpublic Files.TailLinesNonBlockingBuilder chunkSize(int chunkSize)
chunkSize
- chunk size in bytespublic Files.TailLinesNonBlockingBuilder charset(Charset charset)
charset
- charset to decode withpublic Files.TailLinesNonBlockingBuilder charset(String charset)
charset
- charset to decode the file withpublic Files.TailLinesNonBlockingBuilder utf8()
public Files.TailLinesNonBlockingBuilder modifier(WatchEvent.Modifier modifier)
public Files.TailLinesNonBlockingBuilder backpressureStrategy(io.reactivex.BackpressureStrategy backpressureStrategy)
public io.reactivex.Flowable<String> build()
Copyright © 2018s–2019. All rights reserved.