final class DirectoryChangesSource[T] extends GraphStage[SourceShape[T]]
INTERNAL API
Watches a file system directory and streams change events from it.
Note that the JDK watcher is notoriously slow on some platform (up to 1s after event actually happened on OSX for example)
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DirectoryChangesSource
- GraphStage
- GraphStageWithMaterializedValue
- Graph
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new DirectoryChangesSource(directoryPath: Path, pollInterval: FiniteDuration, maxBufferSize: Int, combiner: BiFunction[Path, DirectoryChange, T])
Type Members
-
type
Shape = SourceShape[T]
- Definition Classes
- Graph
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
addAttributes(attr: Attributes): Graph[SourceShape[T], NotUsed]
- Definition Classes
- Graph
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
async(dispatcher: String, inputBufferSize: Int): Graph[SourceShape[T], NotUsed]
- Definition Classes
- Graph
-
def
async(dispatcher: String): Graph[SourceShape[T], NotUsed]
- Definition Classes
- Graph
-
def
async: Graph[SourceShape[T], NotUsed]
- Definition Classes
- Graph
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
def
createLogic(inheritedAttributes: Attributes): GraphStageLogic
- Definition Classes
- DirectoryChangesSource → GraphStage
-
final
def
createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)
- Definition Classes
- GraphStage → GraphStageWithMaterializedValue
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
initialAttributes(): Attributes
- Definition Classes
- DirectoryChangesSource → GraphStageWithMaterializedValue
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
named(name: String): Graph[SourceShape[T], NotUsed]
- Definition Classes
- Graph
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
shape(): SourceShape[T]
- Definition Classes
- DirectoryChangesSource → Graph
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- DirectoryChangesSource → AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
withAttributes(attr: Attributes): Graph[SourceShape[T], NotUsed]
- Definition Classes
- GraphStageWithMaterializedValue → Graph