class Probe[T] extends ManualProbe[T]
Single subscription and demand tracking for TestPublisher.ManualProbe.
- Source
- StreamTestKit.scala
- Alphabetic
- By Inheritance
- Probe
- ManualProbe
- Publisher
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Type Members
-
type
Self = Probe[T]
- Definition Classes
- Probe → ManualProbe
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (Probe[T], B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
ensureSubscription(): Unit
Asserts that a subscription has been received or will be received
- def ensuring(cond: (Probe[T]) ⇒ Boolean, msg: ⇒ Any): Probe[T]
- def ensuring(cond: (Probe[T]) ⇒ Boolean): Probe[T]
- def ensuring(cond: Boolean, msg: ⇒ Any): Probe[T]
- def ensuring(cond: Boolean): Probe[T]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def expectCancellation(): Self
-
def
expectEventPF[T](f: PartialFunction[PublisherEvent, T]): T
- Definition Classes
- ManualProbe
-
def
expectNoMsg(max: FiniteDuration): Self
Expect no messages for a given duration.
Expect no messages for a given duration.
- Definition Classes
- ManualProbe
-
def
expectNoMsg(): Self
Expect no messages.
Expect no messages.
- Definition Classes
- ManualProbe
- def expectRequest(): Long
-
def
expectRequest(subscription: Subscription, n: Int): Self
Expect demand from a given subscription.
Expect demand from a given subscription.
- Definition Classes
- ManualProbe
-
def
expectSubscription(): PublisherProbeSubscription[T]
Expect a subscription.
Expect a subscription.
- Definition Classes
- ManualProbe
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def formatted(fmtstr: String): String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
getPublisher: Publisher[T]
- Definition Classes
- ManualProbe
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
pending: Long
Current pending requests.
-
def
receiveWhile[T](max: Duration = Duration.Undefined, idle: Duration = Duration.Inf, messages: Int = Int.MaxValue)(f: PartialFunction[PublisherEvent, T]): Seq[T]
Receive messages for a given duration or until one does not match a given partial function.
Receive messages for a given duration or until one does not match a given partial function.
- Definition Classes
- ManualProbe
- def sendComplete(): Self
- def sendError(cause: Exception): Self
- def sendNext(elem: T): Self
-
def
subscribe(subscriber: Subscriber[_ >: T]): Unit
Subscribes a given org.reactivestreams.Subscriber to this probe publisher.
Subscribes a given org.reactivestreams.Subscriber to this probe publisher.
- Definition Classes
- ManualProbe → Publisher
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- def unsafeSendNext(elem: T): Self
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
within[T](max: FiniteDuration)(f: ⇒ T): T
Same as calling
within(0 seconds, max)(f)
.Same as calling
within(0 seconds, max)(f)
.- Definition Classes
- ManualProbe
-
def
within[T](min: FiniteDuration, max: FiniteDuration)(f: ⇒ T): T
Execute code block while bounding its execution time between
min
andmax
.Execute code block while bounding its execution time between
min
andmax
.within
blocks may be nested. All methods in this trait which take maximum wait times are available in a version which implicitly uses the remaining time governed by the innermost enclosingwithin
block.Note that the timeout is scaled using Duration.dilated, which uses the configuration entry "akka.test.timefactor", while the min Duration is not.
val ret = within(50 millis) { test ! "ping" expectMsgClass(classOf[String]) }
- Definition Classes
- ManualProbe
- def →[B](y: B): (Probe[T], B)