diff --git a/akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala b/akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala index a4499c2a1e..c0923af769 100644 --- a/akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/event/EventStreamSpec.scala @@ -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 {