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

GHExcludeTest in EventStreamSpec, #30675 (#30688)

Browse source
This commit is contained in:
Patrik Nordwall 2021-09-15 11:12:03 +02:00 • committed by GitHub
parent 0a944d4065
commit e22152098e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

27
akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala
View file

@ -73,7 +73,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
"An EventStream" must {
"manage subscriptions" in {
"manage subscriptions" taggedAs GHExcludeTest in {
//#event-bus-start-unsubscriber-scala
val bus = new EventStream(system, true)
bus.startUnsubscriber()
@ -109,7 +109,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
intercept[IllegalArgumentException] { bus.unsubscribe(null) }.getMessage should ===("subscriber is null")
}
"be able to log unhandled messages" in {
"be able to log unhandled messages" taggedAs GHExcludeTest in {
val sys = ActorSystem("EventStreamSpecUnhandled", configUnhandled)
try {
sys.eventStream.subscribe(testActor, classOf[AnyRef])
@ -149,7 +149,9 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
}
}
"manage sub-channels using classes" in {
// Excluded on GH Actions: https://github.com/akka/akka/issues/30675
"manage sub-channels using classes" taggedAs GHExcludeTest in {
val a = new A
val b1 = new B2
val b2 = new B3
@ -182,7 +184,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
}
}
"manage sub-channels using classes and traits (update on subscribe)" in {
"manage sub-channels using classes and traits (update on subscribe)" taggedAs GHExcludeTest in {
val es = new EventStream(system, false)
val tm1 = new CC
val tm2 = new CCATBT
@ -208,7 +210,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
es.unsubscribe(a4.ref, classOf[CCATBT]) should ===(true)
}
"manage sub-channels using classes and traits (update on unsubscribe)" in {
"manage sub-channels using classes and traits (update on unsubscribe)" taggedAs GHExcludeTest in {
val es = new EventStream(system, false)
val tm1 = new CC
val tm2 = new CCATBT
@ -233,7 +235,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
es.unsubscribe(a4.ref, classOf[CCATBT]) should ===(true)
}
"manage sub-channels using classes and traits (update on unsubscribe all)" in {
"manage sub-channels using classes and traits (update on unsubscribe all)" taggedAs GHExcludeTest in {
val es = new EventStream(system, false)
val tm1 = new CC
val tm2 = new CCATBT
@ -258,7 +260,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
es.unsubscribe(a4.ref, classOf[CCATBT]) should ===(true)
}
"manage sub-channels using classes and traits (update on publish)" in {
"manage sub-channels using classes and traits (update on publish)" taggedAs GHExcludeTest in {
val es = new EventStream(system, false)
val tm1 = new CC
val tm2 = new CCATBT
@ -277,7 +279,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
es.unsubscribe(a2.ref, classOf[BT]) should ===(true)
}
"manage sub-channels using classes and traits (unsubscribe classes used with trait)" in {
"manage sub-channels using classes and traits (unsubscribe classes used with trait)" taggedAs GHExcludeTest in {
val es = new EventStream(system, false)
val tm1 = new CC
val tm2 = new CCATBT
@ -302,7 +304,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
es.unsubscribe(a3.ref, classOf[CC]) should ===(true)
}
"manage sub-channels using classes and traits (subscribe after publish)" in {
"manage sub-channels using classes and traits (subscribe after publish)" taggedAs GHExcludeTest in {
val es = new EventStream(system, false)
val tm1 = new CCATBT
val a1, a2 = TestProbe()
@ -325,7 +327,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
es.unsubscribe(a2.ref, classOf[BTT]) should ===(true)
}
"unsubscribe an actor on its termination" in {
"unsubscribe an actor on its termination" taggedAs GHExcludeTest in {
val sys = ActorSystem("EventStreamSpecUnsubscribeOnTerminated", configUnhandledWithDebug)
try {
@ -388,7 +390,6 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
}
}
// Excluded on GH Actions: https://github.com/akka/akka/issues/18630
"not allow initializing a TerminatedUnsubscriber twice" taggedAs GHExcludeTest in {
val sys = ActorSystem(
"MustNotAllowDoubleInitOfTerminatedUnsubscriber",
@ -409,7 +410,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
}
}
"unwatch an actor from unsubscriber when that actor unsubscribes from the stream" in {
"unwatch an actor from unsubscriber when that actor unsubscribes from the stream" taggedAs GHExcludeTest in {
val sys = ActorSystem("MustUnregisterDuringUnsubscribe", configUnhandledWithDebug)
try {
@ -430,7 +431,7 @@ class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
}
}
"unwatch an actor from unsubscriber when that actor unsubscribes from channels it subscribed" in {
"unwatch an actor from unsubscriber when that actor unsubscribes from channels it subscribed" taggedAs GHExcludeTest in {
val sys = ActorSystem("MustUnregisterWhenNoMoreChannelSubscriptions", configUnhandledWithDebug)
try {