Struct InProcessBroker 

pub struct InProcessBroker<B>(/* private fields */);

A broker whose connect is its InProcess transition, so the suites that take any Broker run against the in-process transport.

lifecycle, redelivery_address and the capabilities suites connect the broker they are handed with Broker::connect, which is what their live pass needs. Wrapping the production broker in this runs the same suite a second time without a server: the connected form, and so every descriptor and publish policy, is the production one, only the transport underneath is the in-process one.

Examples

use ruststream::conformance::harness::{self, InProcessBroker};
use ruststream::memory::{MemoryBroker, MemorySource};

harness::lifecycle(
    || InProcessBroker::new(MemoryBroker::new()),
    |name| MemorySource::new(name),
    |connected| connected.publisher(),
)
.await;

Implementations

impl<B> InProcessBroker<B>

pub const fn new(broker: B) -> Self

Wraps broker, the production broker a service builds its app on.

Examples

use std::time::Duration;

use ruststream::conformance::harness::InProcessBroker;
use ruststream::conformance::settlement;
use ruststream::memory::{MemoryBroker, MemorySource};

// The settlement suite again, on the production broker's in-process transport.
let broker = MemoryBroker::new();
settlement::suite(
    || InProcessBroker::new(broker.clone()),
    |name| MemorySource::new(name),
    |connected| connected.publisher(),
    Duration::ZERO,
)
.await;

Trait Implementations

impl<B: InProcess> Broker for InProcessBroker<B>

type Error = <B as Broker>::Error

The error type returned by broker-level operations.

type Connected = <B as Broker>::Connected

The connected form of this broker: the typed witness that connect succeeded.

fn connect( self, ) -> impl Future<Output = Result<Self::Connected, Self::Error>> + Send

Establishes the connection to the broker, consuming the unconnected form.

fn bindable(self) -> Bindable<Self>

where Self: 'static,

Wraps the broker for publisher-token minting before registration: the returned Bindable hands out Bound tokens via its bind, and is itself what with_broker takes.

impl<B: Clone> Clone for InProcessBroker<B>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B: Debug> Debug for InProcessBroker<B>

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

Formats the value using the given formatter.