Module pubsub 

PubSub abstraction for distributed messaging.

This module provides traits for publish/subscribe messaging patterns, with implementations for NATS and an in-memory stub for testing.

Structs

Message

Message received from a subscription.

StubBus

Shared state for stub publisher/subscriber pairs.

StubPublisher

Stub implementation of the Publisher trait for testing.

StubSubscriber

Stub implementation of the Subscriber trait for testing.

Traits

Publisher

Publisher trait for sending messages to subjects.

Subscriber

Subscriber trait for receiving messages from subjects.

Type Aliases

Subscription

A subscription stream that yields messages.