Skip to content

Commit

Permalink
Bugfix
Browse files Browse the repository at this point in the history
  • Loading branch information
YuanYuYuan committed Mar 14, 2024
1 parent f089673 commit 810df22
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
2 changes: 1 addition & 1 deletion io/zenoh-links/zenoh-link-tcp/src/unicast.rs
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ use super::{
use tokio::net::{TcpListener, TcpSocket, TcpStream};

pub struct LinkUnicastTcp {
// The underlying socket as returned from the async-std library
// The underlying socket as returned from the tokio library
socket: UnsafeCell<TcpStream>,
// The source socket address of this link (address used on the local host)
src_addr: SocketAddr,
Expand Down
5 changes: 3 additions & 2 deletions zenoh/src/publication.rs
Original file line number Diff line number Diff line change
Expand Up @@ -459,14 +459,15 @@ impl<'a> HasWriteWithSampleKind for Publisher<'a> {
///
/// # Examples
/// ```
/// # async_std::task::block_on(async {
/// # #[tokio::main]
/// # async fn main() {
/// use zenoh::prelude::r#async::*;
/// use zenoh::publication::HasWriteWithSampleKind;
///
/// let session = zenoh::open(config::peer()).res().await.unwrap().into_arc();
/// let publisher = session.declare_publisher("key/expression").res().await.unwrap();
/// publisher.write(SampleKind::Put, "value").res().await.unwrap();
/// # })
/// # }
/// ```
fn write<IntoValue>(&self, kind: SampleKind, value: IntoValue) -> Self::WriteOutput<'_>
where
Expand Down

0 comments on commit 810df22

Please sign in to comment.