case class RescanStarted(completeRescanEarlyP: Promise[Option[Int]], blocksMatchedF: Future[Vector[BlockMatchingResponse]], recursiveRescanP: Promise[RescanState])(implicit ec: ExecutionContext) extends RescanState with Product with Serializable
Indicates a rescan has bene started The promise completeRescanEarlyP
gives us the ability to terminate the rescan early by completing the
promise blocksMatchedF is a future that is completed when the rescan
is done this returns all blocks that were matched during the rescan.
recursiveRescanP If the rescan is continued with a fresh pool of
addresses it completes recursiveRescanP with the new
RescanState.RescanStarted. If the rescan is done because
addressGapLimit is satisfied, recursiveRescanP with
RescanState.RescanNotNeeded
- Alphabetic
- By Inheritance
- RescanStarted
- Serializable
- Product
- Equals
- RescanState
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new RescanStarted(completeRescanEarlyP: Promise[Option[Int]], blocksMatchedF: Future[Vector[BlockMatchingResponse]], recursiveRescanP: Promise[RescanState])(implicit ec: ExecutionContext)
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val blocksMatchedF: Future[Vector[BlockMatchingResponse]]
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def entireRescanDoneF: Future[Vector[BlockMatchingResponse]]
Means the entire rescan is done (including recursive rescans).
Means the entire rescan is done (including recursive rescans). This future is completed when we rescan filters with addresses do not contain funds within WalletAppConfig.addressGapLimit
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def fail(err: Throwable): Unit
Fails a rescan with the given exception
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def isCompletedEarly: Boolean
Useful for determining if the rescan was completed externally by the promise to terminate the stream or was completed because the rescan was fully executed
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isStopped: Boolean
- 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 productElementNames: Iterator[String]
- Definition Classes
- Product
- val recursiveRescanP: Promise[RescanState]
- def singleRescanDoneF: Future[Vector[BlockMatchingResponse]]
Means this single rescan is complete, but recursive rescans may not be completed
- def stop(): Future[Vector[BlockMatchingResponse]]
Completes the stream that the rescan in progress uses.
Completes the stream that the rescan in progress uses. This aborts the rescan early.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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()