Modifier and Type | Method and Description |
---|---|
Files.TailBytesNonBlockingBuilder |
Files.TailBytesNonBlockingBuilder.backpressureStrategy(io.reactivex.BackpressureStrategy backpressureStrategy) |
Files.TailBytesNonBlockingBuilder |
Files.TailBytesNonBlockingBuilder.chunkSize(int chunkSize)
Emissions from the tailed file will be no bigger than this.
|
Files.TailBytesNonBlockingBuilder |
Files.TailBytesNonBlockingBuilder.modifier(WatchEvent.Modifier modifier) |
Files.TailBytesNonBlockingBuilder |
Files.TailBytesBuilder.nonBlocking()
Uses
WatchService.poll() under the covers. |
Files.TailBytesNonBlockingBuilder |
Files.TailBytesNonBlockingBuilder.pollingInterval(long pollingInterval,
TimeUnit unit) |
Files.TailBytesNonBlockingBuilder |
Files.TailBytesNonBlockingBuilder.pollingInterval(long pollingInterval,
TimeUnit unit,
io.reactivex.Scheduler scheduler) |
Files.TailBytesNonBlockingBuilder |
Files.TailBytesNonBlockingBuilder.startPosition(long startPosition)
The startPosition in bytes in the file to commence the tail from.
|
Copyright © 2018s–2019. All rights reserved.