bevy_stdb 0.7.3

A Bevy-native integration for SpacetimeDB with table messages, subscriptions, and reconnect support.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

//! [`MessageReader`] type aliases for connection lifecycle and table messages.
use crate::message::{
    DeleteMessage, InsertMessage, InsertUpdateMessage, RequestStdbConnectionMessage,
    StdbConnectedMessage, StdbConnectionErrorMessage, StdbDisconnectedMessage,
    StdbSubscriptionAppliedMessage, StdbSubscriptionErrorMessage, UpdateMessage,
};
use bevy_ecs::prelude::{MessageReader, MessageWriter};

/// A [`MessageReader`] for [`InsertMessage<T>`].
pub type ReadInsertMessage<'w, 's, T> = MessageReader<'w, 's, InsertMessage<T>>;

/// A [`MessageReader`] for [`UpdateMessage<T>`].
pub type ReadUpdateMessage<'w, 's, T> = MessageReader<'w, 's, UpdateMessage<T>>;

/// A [`MessageReader`] for [`DeleteMessage<T>`].
pub type ReadDeleteMessage<'w, 's, T> = MessageReader<'w, 's, DeleteMessage<T>>;

/// A [`MessageReader`] for [`InsertUpdateMessage<T>`].
pub type ReadInsertUpdateMessage<'w, 's, T> = MessageReader<'w, 's, InsertUpdateMessage<T>>;

/// A [`MessageReader`] for [`StdbConnectedMessage`].
pub type ReadStdbConnectedMessage<'w, 's> = MessageReader<'w, 's, StdbConnectedMessage>;

/// A [`MessageReader`] for [`StdbDisconnectedMessage`].
pub type ReadStdbDisconnectedMessage<'w, 's> = MessageReader<'w, 's, StdbDisconnectedMessage>;

/// A [`MessageReader`] for [`StdbConnectionErrorMessage`].
pub type ReadStdbConnectionErrorMessage<'w, 's> = MessageReader<'w, 's, StdbConnectionErrorMessage>;

/// A [`MessageReader`] for [`RequestStdbConnectionMessage`].
pub type ReadRequestStdbConnectionMessage<'w, 's> =
    MessageReader<'w, 's, RequestStdbConnectionMessage>;

/// A [`MessageWriter`] for [`RequestStdbConnectionMessage`].
pub type WriteRequestStdbConnectionMessage<'w> = MessageWriter<'w, RequestStdbConnectionMessage>;

/// A [`MessageReader`] for [`StdbSubscriptionAppliedMessage<K>`].
pub type ReadStdbSubscriptionAppliedMessage<'w, 's, K> =
    MessageReader<'w, 's, StdbSubscriptionAppliedMessage<K>>;

/// A [`MessageReader`] for [`StdbSubscriptionErrorMessage<K>`].
pub type ReadStdbSubscriptionErrorMessage<'w, 's, K> =
    MessageReader<'w, 's, StdbSubscriptionErrorMessage<K>>;