diff --git a/overwatch-rs/src/services/relay.rs b/overwatch-rs/src/services/relay.rs index 7bbe97a..9f17fb4 100644 --- a/overwatch-rs/src/services/relay.rs +++ b/overwatch-rs/src/services/relay.rs @@ -109,7 +109,7 @@ impl InboundRelay { } } -impl OutboundRelay { +impl OutboundRelay { /// Send a message to the relay connection pub async fn send(&self, message: M) -> Result<(), (RelayError, M)> { self.sender @@ -134,7 +134,9 @@ impl OutboundRelay { .blocking_send(message) .map_err(|e| (RelayError::Send, e.0)) } +} +impl OutboundRelay { pub fn into_sink(self) -> impl Sink { PollSender::new(self.sender) }