Struct FakeJetstream 

pub struct FakeJetstream { /* private fields */ }

A fake Jetstream that can emit synthetic events for testing.

Events are sent through a channel and can be consumed by the application’s event handler.

Implementations

impl FakeJetstream

pub fn new(capacity: usize) -> Self

Create a new fake Jetstream with a bounded channel.

pub fn take_receiver(&mut self) -> Option<Receiver<Value>>

Take the receiver (for wiring into the consumer).

pub async fn emit(&self, event: Value) -> Result<()>

Emit a raw event.

pub async fn emit_post(&self, did: &str, rkey: &str, text: &str) -> Result<()>

Emit a synthetic post commit event.

pub async fn emit_follow( &self, did: &str, rkey: &str, target_did: &str, ) -> Result<()>

Emit a synthetic follow event.

pub async fn emit_like( &self, did: &str, rkey: &str, subject_uri: &str, ) -> Result<()>

Emit a synthetic like event.