Struct InRound 

pub struct InRound;

The reply transform that puts a reply in the round of the delivery it answers.

A reply is published after the handler returns and before the delivery settles. Mounted on the reply position of a .pipeline() subscription, this transform queues it into the delivery’s segment instead: it leaves with the window, after what the handler queued, and under .atomic() inside the delivery’s MULTI / EXEC. On a subscription without a window the reply leaves at once, as it does without the transform.

Examples

use ruststream_fred::stream::prelude::*;
use serde::Serialize;
#[derive(Serialize, Outgoing)]
#[outgoing(name = "receipts")]
struct Receipt {
    id: u64,
}

#[subscriber(RedisStream::new("orders").group("workers"), reply)]
async fn issue(order: &Order) -> Receipt {
    Receipt { id: order.id }
}

fn app() -> RustStream {
    RustStream::new(AppInfo::new("receipts", "0.1.0")).with_broker(
        RedisBroker::standalone("redis://localhost:6379"),
        |b| {
            b.include(issue.pipeline()).out_reply(Publish).transform(InRound);
        },
    )
}

Trait Implementations

impl Clone for InRound

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for InRound

impl Debug for InRound

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

Formats the value using the given formatter.

impl Default for InRound

fn default() -> Self

Returns the “default value” for a type.

impl Eq for InRound

impl PartialEq for InRound

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

Equality operator ==.

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

Inequality operator !=.

impl<C> PublishTransform<ForReply<C>, RedisPublishOptions> for InRound

type Destination = Reads

What this transform does to the destination: Reads or Names.

fn apply( &self, _out: &mut Outgoing<'_>, options: &mut Option<RedisPublishOptions>, _cx: &PublishContext<'_, C>, )

Transforms out in place before it is sent, reading the position’s view through cx and resolving the broker’s per-message settings through options.

impl StructuralPartialEq for InRound