Skip to content

Commit

Permalink
Fix some missed merge conflicts
Browse files Browse the repository at this point in the history
  • Loading branch information
Carter committed Oct 17, 2024
1 parent e62cfaa commit 571f405
Showing 1 changed file with 0 additions and 8 deletions.
8 changes: 0 additions & 8 deletions roslibrust/src/ros1/subscriber.rs
Original file line number Diff line number Diff line change
@@ -1,11 +1,7 @@
use crate::ros1::{names::Name, tcpros::ConnectionHeader};
use abort_on_drop::ChildTask;
use log::*;
<<<<<<< HEAD
use roslibrust_codegen::{RosMessageType, ShapeShifter};
=======
use roslibrust_codegen::RosMessageType;
>>>>>>> Switch to fork of serde_rosmsg, benchmark that it is indeed much faster, fix bug with missing write_all
use std::{marker::PhantomData, sync::Arc};
use tokio::{
io::AsyncWriteExt,
Expand Down Expand Up @@ -170,15 +166,11 @@ impl Subscription {
);
match tcpros::receive_body(&mut stream).await {
Ok(body) => {
<<<<<<< HEAD
trace!(
"Subscription to {} receiving from {} received body",
topic_name,
publisher_uri
);
=======
trace!("Got new message from publisher {publisher_uri} on {topic_name}");
>>>>>>> Switch to fork of serde_rosmsg, benchmark that it is indeed much faster, fix bug with missing write_all
let send_result = sender.send(body);
if let Err(err) = send_result {
log::error!("Unable to send message data due to dropped channel, closing connection: {err}");
Expand Down

0 comments on commit 571f405

Please sign in to comment.