Packages

c

org.bitcoins.node.callback

NodeCallbackStreamManager

case class NodeCallbackStreamManager(callbacks: NodeCallbacks, overflowStrategy: OverflowStrategy = OverflowStrategy.backpressure, maxBufferSize: Int = 16)(implicit system: ActorSystem) extends NodeCallbacks with StartStopAsync[Unit] with BitcoinSLogger with Product with Serializable

Creates a wrapper around the give node callbacks with a stream

Linear Supertypes
Serializable, Product, Equals, StartStopAsync[Unit], StartStop[Future[Unit]], NodeCallbacks, BitcoinSLogger, ModuleCallbacks[NodeCallbacks], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. NodeCallbackStreamManager
  2. Serializable
  3. Product
  4. Equals
  5. StartStopAsync
  6. StartStop
  7. NodeCallbacks
  8. BitcoinSLogger
  9. ModuleCallbacks
  10. AnyRef
  11. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new NodeCallbackStreamManager(callbacks: NodeCallbacks, overflowStrategy: OverflowStrategy = OverflowStrategy.backpressure, maxBufferSize: Int = 16)(implicit system: ActorSystem)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. def +(other: NodeCallbacks): NodeCallbacks

    Consider calling stop() before creating a new instance of callbacks this is because the previous stream will keep running and a new stream will be created

    Consider calling stop() before creating a new instance of callbacks this is because the previous stream will keep running and a new stream will be created

    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks → ModuleCallbacks
  4. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. val callbacks: NodeCallbacks
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def executeOnBlockHeadersReceivedCallbacks(headers: Vector[BlockHeader])(implicit ec: ExecutionContext): Future[Unit]
    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks
  10. def executeOnBlockReceivedCallbacks(block: Block)(implicit ec: ExecutionContext): Future[Unit]
    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks
  11. def executeOnCompactFiltersReceivedCallbacks(blockFilters: Vector[(DoubleSha256DigestBE, GolombFilter)])(implicit ec: ExecutionContext): Future[Unit]
    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks
  12. def executeOnMerkleBlockReceivedCallbacks(merkleBlock: MerkleBlock, txs: Vector[Transaction])(implicit ec: ExecutionContext): Future[Unit]
    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks
  13. def executeOnTxReceivedCallbacks(tx: Transaction)(implicit ec: ExecutionContext): Future[Unit]
    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks
  14. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  15. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. def logger: Logger
    Definition Classes
    BitcoinSLogger
  18. val maxBufferSize: Int
  19. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. def onBlockHeadersReceived: CallbackHandler[Vector[BlockHeader], OnBlockHeadersReceived]
    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks
  23. def onBlockReceived: CallbackHandler[Block, OnBlockReceived]
    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks
  24. def onCompactFiltersReceived: CallbackHandler[Vector[(DoubleSha256DigestBE, GolombFilter)], OnCompactFiltersReceived]
    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks
  25. def onMerkleBlockReceived: CallbackHandler[(MerkleBlock, Vector[Transaction]), OnMerkleBlockReceived]
    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks
  26. def onTxReceived: CallbackHandler[Transaction, OnTxReceived]
    Definition Classes
    NodeCallbackStreamManager → NodeCallbacks
  27. val overflowStrategy: OverflowStrategy
  28. def productElementNames: Iterator[String]
    Definition Classes
    Product
  29. def start(): Future[Unit]
    Definition Classes
    NodeCallbackStreamManager → StartStop
  30. def stop(): Future[Unit]

    Completes all streams and waits until they are fully drained

    Completes all streams and waits until they are fully drained

    Definition Classes
    NodeCallbackStreamManager → StartStop
  31. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  32. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  33. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  34. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from StartStopAsync[Unit]

Inherited from StartStop[Future[Unit]]

Inherited from NodeCallbacks

Inherited from BitcoinSLogger

Inherited from ModuleCallbacks[NodeCallbacks]

Inherited from AnyRef

Inherited from Any

Ungrouped