Skip to content

Commit b0469d3

Browse files
committed
builds and all tests pass
1 parent 6b32b76 commit b0469d3

File tree

4 files changed

+7
-7
lines changed

4 files changed

+7
-7
lines changed

src/communication/NotificationSink.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,6 @@ NotificationSink::SinkOrStatus NotificationSink::create(
7878
NotificationSink::NotificationSink(
7979
std::shared_ptr<transport::UTransport> transport,
8080
NotificationSink::ListenHandle&& listener)
81-
: transport_(std::move(transport)), listener_(listener) {}
81+
: transport_(std::move(transport)), listener_(std::move(listener)) {}
8282

8383
} // namespace uprotocol::communication

src/communication/RpcClient.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ struct RpcClient::ExpireService {
7171
std::function<void(v1::UStatus)> expire) const {
7272
detail::PendingRequest pending;
7373
pending.when_expire = when_expire;
74-
pending.response_listener = response_listener;
74+
pending.response_listener = std::move(response_listener);
7575
pending.expire = std::move(expire);
7676
pending.instance_id = instance_id_;
7777

@@ -128,7 +128,7 @@ RpcClient::InvokeHandle RpcClient::invokeMethod(v1::UMessage&& request,
128128

129129
auto connected_pair =
130130
Connection::establish(std::move(callback));
131-
auto callback_handle = std::get<0>(connected_pair);
131+
auto callback_handle = std::move(std::get<0>(connected_pair));
132132
auto callable = std::get<1>(connected_pair);
133133

134134
///////////////////////////////////////////////////////////////////////////
@@ -240,7 +240,7 @@ RpcClient::InvokeFuture& RpcClient::InvokeFuture::operator=(
240240

241241
RpcClient::InvokeFuture::InvokeFuture(std::future<MessageOrStatus>&& future,
242242
InvokeHandle&& handle) noexcept
243-
: callback_handle_(handle), future_(std::move(future)) {}
243+
: callback_handle_(std::move(handle)), future_(std::move(future)) {}
244244

245245
} // namespace uprotocol::communication
246246

@@ -355,7 +355,7 @@ void ExpireWorker::doWork() {
355355
if (when_expire <= now) {
356356
maybe_expire = std::move(pending_.top().expire);
357357
expired_handle =
358-
pending_.top().response_listener;
358+
std::move(pending_.top().response_listener);
359359
pending_.pop();
360360
}
361361
}

src/communication/Subscriber.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ namespace uri_validator = uprotocol::datamodel::validator::uri;
4747

4848
Subscriber::Subscriber(std::shared_ptr<transport::UTransport> transport,
4949
ListenHandle&& subscription)
50-
: transport_(std::move(transport)), subscription_(subscription) {
50+
: transport_(std::move(transport)), subscription_(std::move(subscription)) {
5151
// Constructor body. Any additional setup can go here.
5252
if (!transport_) {
5353
throw transport::NullTransport("transport cannot be null");

src/transport/UTransport.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ UTransport::HandleOrStatus UTransport::registerListener(
8989
std::move(callable), source_filter, std::move(sink_filter));
9090

9191
if (status.code() == v1::UCode::OK) {
92-
return HandleOrStatus(handle);
92+
return HandleOrStatus(std::move(handle));
9393
}
9494
return HandleOrStatus(utils::Unexpected<v1::UStatus>(status));
9595
}

0 commit comments

Comments
 (0)