Struct DefaultSlot 

pub struct DefaultSlot;

The implicit marker of a single unnamed Out<impl Publisher> parameter.

A handler with one Out parameter needs no marker: the parameter binds to this slot, and the include site attaches its policy by naming the marker like any other, .out(DefaultSlot, policy).

Examples

use ruststream::memory::prelude::*;
use serde::{Deserialize, Serialize};

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

#[derive(Serialize, Outgoing)]
#[outgoing(name = "orders.accepted")]
struct Accepted {
    id: u64,
}

/// One `Out` parameter and no marker: it binds to `DefaultSlot`.
#[subscriber("orders")]
async fn accept(order: &Order, Out(out): Out<impl Publisher>) -> HandlerOutcome {
    match out.message(&Accepted { id: order.id }).publish().await {
        Ok(()) => HandlerOutcome::ack(),
        Err(_) => HandlerOutcome::retry(),
    }
}

fn app() -> RustStream {
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(MemoryBroker::new(), |b| {
        b.include(accept).out(DefaultSlot, Publish).build();
    })
}

Trait Implementations

impl Clone for DefaultSlot

fn clone(&self) -> DefaultSlot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for DefaultSlot

impl Debug for DefaultSlot

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

Formats the value using the given formatter.

impl Default for DefaultSlot

fn default() -> DefaultSlot

Returns the “default value” for a type.

impl Eq for DefaultSlot

impl Hash for DefaultSlot

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl OutSlot for DefaultSlot

const NAME: &'static str = "default"

The human-readable slot name, used by diagnostics and test assertions.

type Destination = Reads

The most a transform on this slot may do to a message’s destination.

fn outgoing() -> Vec<OutgoingMessageMetadata>

The slot’s publish dictionary as AsyncAPI metadata, one entry per #[publishes(..)] type. The derive fills this in; the default (a marker without a dictionary) publishes nothing declared. Called once at registration; never on the publish path.

impl PartialEq for DefaultSlot

fn eq(&self, other: &DefaultSlot) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for DefaultSlot