Skip to content

Commit a07a0f5

Browse files
REQREPLY-221: Fix fix format
1 parent b4ff04a commit a07a0f5

File tree

3 files changed

+6
-9
lines changed

3 files changed

+6
-9
lines changed

examples/connext_dds/remote_procedure_call/c++11/Inventory_service.cxx

+1-4
Original file line numberDiff line numberDiff line change
@@ -81,10 +81,7 @@ class InventoryImpl : public InventoryService {
8181
std::mutex mutex;
8282
};
8383

84-
void run_server(
85-
int domain_id,
86-
unsigned int delay,
87-
unsigned int service_timeout)
84+
void run_server(int domain_id, unsigned int delay, unsigned int service_timeout)
8885
{
8986
// Create a DomainParticipant with default Qos. The Service will communicate
9087
// only with Clients that join the same domain_id

examples/connext_dds/remote_procedure_call/py/inventory_client.py

+2-5
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,7 @@
1717
from Inventory import Item, InventoryService, UnknownItemError
1818

1919

20-
class InventoryClient(InventoryService, rpc.ClientBase):
21-
...
20+
class InventoryClient(InventoryService, rpc.ClientBase): ...
2221

2322

2423
async def run_client(args):
@@ -50,9 +49,7 @@ async def run_client(args):
5049
def main():
5150
parser = argparse.ArgumentParser(description="Inventory client")
5251
group = parser.add_mutually_exclusive_group(required=True)
53-
group.add_argument(
54-
"-r", "--remove", type=str, help="Remove item from inventory"
55-
)
52+
group.add_argument("-r", "--remove", type=str, help="Remove item from inventory")
5653
group.add_argument("-a", "--add", type=str, help="Add item to inventory")
5754

5855
parser.add_argument(

examples/connext_dds/remote_procedure_call/py/inventory_service.py

+3
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
UnknownItemError,
2424
)
2525

26+
2627
class InventoryImpl(InventoryService):
2728
"""Implements a simple InventoryService"""
2829

@@ -59,12 +60,14 @@ async def remove_item(self, item: Item):
5960
if self.inventory[item.name] <= 0:
6061
del self.inventory[item.name]
6162

63+
6264
async def run_service(service: rpc.Service):
6365
try:
6466
await service.run(close_on_cancel=True)
6567
except asyncio.CancelledError:
6668
pass
6769

70+
6871
async def main():
6972
parser = argparse.ArgumentParser(description="Inventory client")
7073
parser.add_argument(

0 commit comments

Comments
 (0)