pub async fn publish_event<S, D>(&mut self, topic: S, data: D) -> Result<()>
    where
        S: Into<String>,
        D: IntoAny,
    {
        self.0
            .publish_event(Request::new(PublishEventEnvelope {
                topic: topic.into(),
                data: data.into_any(),
            }))
            .await
            .map(|res| res.into_inner())
            .map_err(Error::from)
    }
/// Publish a payload to multiple consumers who are listening on a topic.
///
/// Dapr guarantees at least once semantics for this endpoint.
Publish a payload to multiple consumers who are listening on a topic.
Dapr guarantees at least once semantics for this endpoint.
Publish a payload to multiple consumers who are listening on a topic . Dapr guarantees at least once semantics for this endpoint .
pub async fn publish_event<S, D>(&mut self, topic: S, data: D) -> Result<()>
    where
        S: Into<String>,
        D: IntoAny,
    {
        self.0
            .publish_event(Request::new(PublishEventEnvelope {
                topic: topic.into(),
                data: data.into_any(),
            }))
            .await
            .map(|res| res.into_inner())
            .map_err(Error::from)
    }
pub async fn publish_event < S , D > ( & mut self , topic : S , data : D ) -> Result < ( ) > where S : Into < String > , D : IntoAny , { self . 0 . publish_event ( Request :: new ( PublishEventEnvelope { topic : topic . into ( ) , data : data . into_any ( ) , } ) ) . await . map ( | res | res . into_inner ( ) ) . map_err ( Error :: from ) }
Publish a payload to multiple consumers who are listening on a topic.
Publish a payload to multiple consumers who are listening on a topic .
&mut self
topic
S
data
D
&mut self
topic
S
data
D