raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

with deprecated code, highlight versions are Akka versions (#154)

Browse source 
* with deprecated code, highlight versions are Akka versions

* scalafmt issue
This commit is contained in:
PJ Fanning 2023-02-09 14:39:56 +01:00 • committed by GitHub
parent 8338bfed8b
commit d0238d8bf7
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
65 changed files with 308 additions and 307 deletions
Download patch file Download diff file Expand all files Collapse all files

8
stream-testkit/src/main/scala/org/apache/pekko/stream/testkit/StreamTestKit.scala
View file

@ -155,7 +155,7 @@ object TestPublisher {
* Expect no messages.
* NOTE! Timeout value is automatically multiplied by timeFactor.
*/
@deprecated(message = "Use expectNoMessage instead", since = "2.5.5")
@deprecated(message = "Use expectNoMessage instead", since = "Akka 2.5.5")
def expectNoMsg(): Self = executeAfterSubscription {
probe.expectNoMsg()
self
@ -165,7 +165,7 @@ object TestPublisher {
* Expect no messages for a given duration.
* NOTE! Timeout value is automatically multiplied by timeFactor.
*/
@deprecated(message = "Use expectNoMessage instead", since = "2.5.5")
@deprecated(message = "Use expectNoMessage instead", since = "Akka 2.5.5")
def expectNoMsg(max: FiniteDuration): Self = executeAfterSubscription {
probe.expectNoMsg(max)
self
@ -649,7 +649,7 @@ object TestSubscriber {
* Same as `expectNoMsg(remaining)`, but correctly treating the timeFactor.
* NOTE! Timeout value is automatically multiplied by timeFactor.
*/
@deprecated(message = "Use expectNoMessage instead", since = "2.5.5")
@deprecated(message = "Use expectNoMessage instead", since = "Akka 2.5.5")
def expectNoMsg(): Self = {
probe.expectNoMsg()
self
@ -661,7 +661,7 @@ object TestSubscriber {
* Assert that no message is received for the specified time.
* NOTE! Timeout value is automatically multiplied by timeFactor.
*/
@deprecated(message = "Use expectNoMessage instead", since = "2.5.5")
@deprecated(message = "Use expectNoMessage instead", since = "Akka 2.5.5")
def expectNoMsg(remaining: FiniteDuration): Self = {
probe.expectNoMsg(remaining)
self