Packages

object RescanState

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RescanState
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. 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.

    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

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def awaitRescanComplete(rescanState: RescanState)(implicit ec: ExecutionContext): Future[Unit]

    Returns a Future that is completed when a rescan is fully executed.

    Returns a Future that is completed when a rescan is fully executed. This means that the rescan was NOT terminated externally by completing the akka stream that underlies the rescan logic.

  6. def awaitRescanDone(rescanState: RescanState)(implicit ec: ExecutionContext): Future[Unit]

    Returns a Future for all rescan states that will be complete when the rescan is done.

    Returns a Future for all rescan states that will be complete when the rescan is done. This can be because the stream was externally termianted early, or the rescan completes. If you are interested in just the stream completing beacuse the rescan was fully executed, use awaitComplete())

  7. def awaitSingleRescanDone(rescanState: RescanState)(implicit ec: ExecutionContext): Future[Unit]
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  19. def toString(): String
    Definition Classes
    AnyRef → Any
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  23. case object RescanAlreadyStarted extends RescanState with Product with Serializable

    A rescan has already been started

  24. case object RescanDone extends RescanState with Product with Serializable

    Finished a rescan

  25. case object RescanNotNeeded extends RescanState with Product with Serializable

    For the case where we do not need to initiate a recursive rescan with a fresh pool of wallet addresses

  26. case object RescanTerminatedEarly extends RuntimeException with Product with Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped