pub async fn query_events(
    axon_server_handle: &AxonServerHandle,
    aggregate_identifier: &str,
) -> Result<Vec<Event>> {
    let axon_server_handle = axon_server_handle.clone();
    let conn = axon_server_handle.conn;
    let mut client = EventStoreClient::new(conn);
    query_events_from_client(&mut client, aggregate_identifier).await
}
/// Fetch all events for a given aggregate.
Fetch all events for a given aggregate.
Fetch all events for a given aggregate .
pub async fn query_events(
    axon_server_handle: &AxonServerHandle,
    aggregate_identifier: &str,
) -> Result<Vec<Event>> {
    let axon_server_handle = axon_server_handle.clone();
    let conn = axon_server_handle.conn;
    let mut client = EventStoreClient::new(conn);
    query_events_from_client(&mut client, aggregate_identifier).await
}
pub async fn query_events ( axon_server_handle : & AxonServerHandle , aggregate_identifier : & str , ) -> Result < Vec < Event > > { let axon_server_handle = axon_server_handle . clone ( ) ; let conn = axon_server_handle . conn ; let mut client = EventStoreClient :: new ( conn ) ; query_events_from_client ( & mut client , aggregate_identifier ) . await }
Fetch all events for a given aggregate.
Fetch all events for a given aggregate .
axon_server_handle
&AxonServerHandle
aggregate_identifier
&str
axon_server_handle
&AxonServerHandle
aggregate_identifier
&str