class ManualProbe[I] extends Publisher[I]
Implementation of org.reactivestreams.Publisher that allows various assertions. This probe does not track demand. Therefore you need to expect demand before sending elements downstream.
- Source
- StreamTestKit.scala
- Alphabetic
- By Inheritance
- ManualProbe
- Publisher
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Type Members
- abstract type Self <: ManualProbe[I]
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from ManualProbe[I] to any2stringadd[ManualProbe[I]] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (ManualProbe[I], B)
- Implicit
- This member is added by an implicit conversion from ManualProbe[I] to ArrowAssoc[ManualProbe[I]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
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
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
def
ensuring(cond: (ManualProbe[I]) ⇒ Boolean, msg: ⇒ Any): ManualProbe[I]
- Implicit
- This member is added by an implicit conversion from ManualProbe[I] to Ensuring[ManualProbe[I]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (ManualProbe[I]) ⇒ Boolean): ManualProbe[I]
- Implicit
- This member is added by an implicit conversion from ManualProbe[I] to Ensuring[ManualProbe[I]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): ManualProbe[I]
- Implicit
- This member is added by an implicit conversion from ManualProbe[I] to Ensuring[ManualProbe[I]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): ManualProbe[I]
- Implicit
- This member is added by an implicit conversion from ManualProbe[I] to Ensuring[ManualProbe[I]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def executeAfterSubscription[T](f: ⇒ T): T
- def expectEventPF[T](f: PartialFunction[PublisherEvent, T]): T
-
def
expectNoMessage(max: FiniteDuration): Self
Expect no messages for a given duration.
-
def
expectNoMessage(): Self
Expect no messages.
-
def
expectRequest(subscription: Subscription, n: Int): Self
Expect demand from a given subscription.
-
def
expectSubscription(): PublisherProbeSubscription[I]
Expect a subscription.
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from ManualProbe[I] to StringFormat[ManualProbe[I]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def getPublisher: Publisher[I]
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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.
-
def
subscribe(subscriber: Subscriber[_ >: I]): 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
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
within[T](max: FiniteDuration)(f: ⇒ T): T
Same as calling
within(0 seconds, max)(f)
. -
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]) }
-
def
→[B](y: B): (ManualProbe[I], B)
- Implicit
- This member is added by an implicit conversion from ManualProbe[I] to ArrowAssoc[ManualProbe[I]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
Deprecated Value Members
-
def
expectNoMsg(max: FiniteDuration): Self
Expect no messages for a given duration.
Expect no messages for a given duration. NOTE! Timeout value is automatically multiplied by timeFactor.
- Annotations
- @deprecated
- Deprecated
(Since version 2.5.5) Use expectNoMessage instead
-
def
expectNoMsg(): Self
Expect no messages.
Expect no messages. NOTE! Timeout value is automatically multiplied by timeFactor.
- Annotations
- @deprecated
- Deprecated
(Since version 2.5.5) Use expectNoMessage instead
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
- Deprecated
(Since version ) see corresponding Javadoc for more information.