-
- All Implemented Interfaces:
-
jetbrains.exodus.io.DataReader
public final class WatchingFileDataReader implements DataReader
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public classWatchingFileDataReader.Companion
-
Constructor Summary
Constructors Constructor Description WatchingFileDataReader(Function0<EnvironmentImpl> envGetter, FileDataReader fileDataReader)
-
Method Summary
Modifier and Type Method Description StringgetLocation()Iterable<Block>getBlocks()Iterable<Block>getBlocks(Long fromAddress)Unitclose()final <ERROR CLASS>addNewDataListener(Function2<Long, Long, Unit> listener)Add callback that is invoked when new data arrives and Environment is successfully updated. final <ERROR CLASS>removeNewDataListener(Function2<Long, Long, Unit> listener)-
-
Constructor Detail
-
WatchingFileDataReader
WatchingFileDataReader(Function0<EnvironmentImpl> envGetter, FileDataReader fileDataReader)
-
-
Method Detail
-
getLocation
String getLocation()
-
addNewDataListener
final <ERROR CLASS> addNewDataListener(Function2<Long, Long, Unit> listener)
Add callback that is invoked when new data arrives and Environment is successfully updated.
-
removeNewDataListener
final <ERROR CLASS> removeNewDataListener(Function2<Long, Long, Unit> listener)
-
-
-
-