   end    @query """   subscription ($clientId: ID!) {     thing(clientId: $clientId)   }   """   test "can subscribe the current process" do     client_id = "abc"      assert {:ok, %{"subscribed" => topic}} =              run_subscription(                @query,                Schema,                variables: %{"clientId" => client_id},                context: %{pubsub: PubSub}              )      Absinthe.Subscription.publish(PubSub, "foo", thing: client_id)      assert_receive({:broadcast, msg})      assert %{              event: "subscription:data",              result: %{data: %{"thing" => "foo"}},              topic: topic            } == msg   end    @query """   subscription ($clientId: ID!) {     thing(clientId: $clientId)   }   """   test "can 