test: checkin

Tochemey · Mar 5, 2025 · 4c8962f · 4c8962f
1 parent bc7038c
commit 4c8962f
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/actor/topic_actor_test.go b/actor/topic_actor_test.go
@@ -98,6 +98,15 @@ func TestTopicActor(t *testing.T) {
 		// make sure we receive the subscribe ack message
 		require.EqualValues(t, 1, actor3.Metric(ctx).ProcessedCount())
 
+		// subscribe to the topic
+		err = actor1.Tell(ctx, cl1.TopicActor(), &goaktpb.Unsubscribe{Topic: topic})
+		require.NoError(t, err)
+
+		util.Pause(time.Second)
+
+		// make sure we receive the subscribe ack message
+		require.EqualValues(t, 2, actor1.Metric(ctx).ProcessedCount())
+
 		require.NoError(t, cl1.Stop(ctx))
 		require.NoError(t, cl2.Stop(ctx))
 		require.NoError(t, cl3.Stop(ctx))