Struct Unnamed 

pub struct Unnamed<S>(/* private fields */);

The stand-in a definition carries while its subscription has no name yet.

#[subscriber] and #[subscriber(Kind)] fix the subscription kind and leave its value to the mount site, so the definition’s source starts as Unnamed<Kind>. It implements no SubscriptionSource: mounting a definition that was never named is a compile error, not a startup one. name replaces it with the kind itself, built through FromName.

Examples

use ruststream::memory::prelude::*;
use serde::Deserialize;

#[derive(Deserialize)]
struct Order {
    id: u64,
}

/// The kind is fixed here; its source stays `Unnamed<MemorySource>` until the mount names it.
#[subscriber(MemorySource)]
async fn audit(order: &Order) -> HandlerOutcome {
    tracing::info!(order.id, "audited");
    HandlerOutcome::ack()
}

fn app(region: &str) -> RustStream {
    RustStream::new(AppInfo::new("audit", "0.1.0")).with_broker(MemoryBroker::new(), |b| {
        b.include(audit.name(format!("orders.{region}")));
    })
}

A definition mounted without a name does not compile:

use ruststream::memory::prelude::*;
use serde::Deserialize;

#[derive(Deserialize)]
struct Order {
    id: u64,
}

#[subscriber(MemorySource)]
async fn audit(order: &Order) -> HandlerOutcome {
    tracing::info!(order.id, "audited");
    HandlerOutcome::ack()
}

fn app() -> RustStream {
    RustStream::new(AppInfo::new("audit", "0.1.0")).with_broker(MemoryBroker::new(), |b| {
        // Never named: there is no subscription to open.
        b.include(audit);
    })
}

Implementations

impl<S> Unnamed<S>

pub const fn new() -> Unnamed<S>

The placeholder for a subscription of kind S whose name is still missing.

pub fn into_named(self, name: impl Into<Cow<'static, str>>) -> S

where S: FromName,

Builds the subscription kind now that its name is known.

Trait Implementations

impl<S> Clone for Unnamed<S>

fn clone(&self) -> Unnamed<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S> Copy for Unnamed<S>

impl<S> Debug for Unnamed<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<S> Default for Unnamed<S>

fn default() -> Unnamed<S>

Returns the “default value” for a type.

impl<S> IntoSource for Unnamed<S>

type Source = Unnamed<S>

The source the constructor stores.

fn into_source(self) -> Unnamed<S>

Builds the source.