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)
- Annotations
- @InternalApi()
- Source
- DirectoryChangesSource.java
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DirectoryChangesSource
- GraphStage
- GraphStageWithMaterializedValue
- Graph
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
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(classOf[java.lang.CloneNotSupportedException]) @native()
- def createLogic(inheritedAttributes: Attributes): GraphStageLogic
- Definition Classes
- DirectoryChangesSource → GraphStage
- Annotations
- @Override()
- final def createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)
- Definition Classes
- GraphStage → GraphStageWithMaterializedValue
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def getAttributes: Attributes
- Definition Classes
- Graph
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def initialAttributes(): Attributes
- Definition Classes
- DirectoryChangesSource → GraphStageWithMaterializedValue
- Annotations
- @Override()
- 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()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def shape(): SourceShape[T]
- Definition Classes
- DirectoryChangesSource → Graph
- Annotations
- @Override()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- DirectoryChangesSource → AnyRef → Any
- Annotations
- @Override()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def withAttributes(attr: Attributes): Graph[SourceShape[T], NotUsed]
- Definition Classes
- GraphStageWithMaterializedValue → Graph