Crate kameo_actors 

General-purpose actors for concurrent programming

This crate provides reusable actor components:

• broker: Topic-based message broker
• message_bus: Type-based message bus
• pool: Actor pool for managing concurrent task execution
• pubsub: Publish-subscribe pattern implementation for actor communication

When to use MessageBus vs Broker vs PubSub

• Use MessageBus when you want to route messages based on their type without explicit topics.
• Use Broker when you need hierarchical topics, pattern-based subscriptions, or explicit routing.
• Use PubSub when you need simple broadcast to all listeners with optional predicate-based filtering.

Modules

broker

Provides a topic-based message broker for the actor system.

message_bus

Provides a type-based message bus for the actor system.

message_queue

Provides an AMQP-style message queue system for the actor system.

pool

Provides a pool of actors for task distribution and load balancing.

pubsub

Provides a publish-subscribe (pubsub) mechanism for actors.

scheduler

Sends messages to actors at scheduled timeouts/intervals.

Enums

DeliveryStrategy

Strategies for delivering messages to subscribers.