Akka Typed version cluster sharding with distributed pubsub

Hi Team,

I am reading this https://doc.akka.io/docs/akka/current/typed/distributed-pub-sub.html. And didn’t found anywhere the actual implementation for this. Concept wise its clear but implementation with Typed version its not there. Could you please do needful?

It was added in Akka 2.6.4 so check that you are on at least that version.

Yes, Akka 2.6.7. Implementation means here, I am looking for Github repo where some sample described with ```
import akka.actor.typed.pubsub.Topic

Behaviors.setup { context =>
val topic = context.spawn(TopicMessage, “MyTopic”)

topic ! Topic.Publish(Message("Hello Subscribers!"))

Sorry, I’m a bit unclear about what you are asking. Are you looking for a sample project showing how to use it, or are you looking for the implementation/internals of the typed topic API in Akka?

Looking for sample project.

I’m afraid we do not have an isolated sample of that. I think we expected that since the API is so minimal there was no real need for a full sample project but that the reference docs would suffice.

The tests for topic could perhaps be useful to look at if the reference docs sample is not enough: https://github.com/akka/akka/blob/master/akka-actor-typed-tests/src/test/scala/akka/actor/typed/pubsub/LocalPubSubSpec.scala