Skip to main content

Module router

Module router 

Source
Expand description

Ergonomic event router for dispatching Jetstream events by collection and operation.

Instead of writing manual match statements in your on_event handler, use EventRouterBuilder to declaratively register handlers per collection and operation type:

use atrg_stream::{EventRouterBuilder, CommitEvent, Operation};

let router = EventRouterBuilder::new()
    .on_create("app.bsky.feed.post", handle_new_post)
    .on_delete("app.bsky.feed.post", handle_deleted_post)
    .on("app.bsky.feed.like", handle_any_like)
    .build();

Structs§

CommitEvent
A typed commit event with extracted fields for handler convenience.
EventRouterBuilder
Builder for constructing an event router.

Enums§

Operation
Operation filter for event routing.

Type Aliases§

RouteHandler
Handler function type for the event router.