run isort on all files

Author: gonzalocasas

src/roslibpy/actionlib.py

@@ -28,8 +28,7 @@
 import threading
 import time
 
-from . import Message
-from . import Topic
+from . import Message, Topic
 from .event_emitter import EventEmitterMixin
 
 __all__ = ["Goal", "GoalStatus", "ActionClient", "SimpleActionServer"]
@@ -109,7 +108,8 @@ def send(self, result_callback=None, timeout=None):
 
         Args:
             timeout (:obj:`int`): Timeout for the goal's result expressed in seconds.
-            callback (:obj:`callable`): Function to be called when a result is received. It is a shorthand for hooking on the ``result`` event.
+            callback (:obj:`callable`): Function to be called when a result is received.
+            It is a shorthand for hooking on the ``result`` event.
         """
         if result_callback:
             self.on("result", result_callback)
@@ -220,7 +220,7 @@ def __init__(
 
         if timeout:
             LOGGER.warn(
-                "Deprecation warning: timeout parameter is ignored, and replaced by the DEFAULT_CONNECTION_TIMEOUT constant."
+                "Deprecation warning: timeout parameter ignored and replaced by DEFAULT_CONNECTION_TIMEOUT constant."
             )
 
         self.wait_status = threading.Event()
@@ -332,7 +332,8 @@ def start(self, action_callback):
         """Start the action server.
 
         Args:
-            action_callback: Callable function to be invoked when a new goal is received. It takes one paramter containing the goal message.
+            action_callback: Callable function to be invoked when a new goal is received.
+            It takes one paramter containing the goal message.
         """
         LOGGER.info("Action server {} started".format(self.server_name))
 

src/roslibpy/comm/__init__.py

@@ -1,7 +1,6 @@
 import sys
 
-from .comm import RosBridgeException
-from .comm import RosBridgeProtocol
+from .comm import RosBridgeException, RosBridgeProtocol
 
 if sys.platform == "cli":
     from .comm_cli import CliRosBridgeClientFactory as RosBridgeClientFactory

src/roslibpy/comm/comm.py

@@ -3,9 +3,7 @@
 import json
 import logging
 
-from roslibpy.core import Message
-from roslibpy.core import MessageEncoder
-from roslibpy.core import ServiceResponse
+from roslibpy.core import Message, MessageEncoder, ServiceResponse
 
 LOGGER = logging.getLogger("roslibpy")
 

src/roslibpy/comm/comm_autobahn.py

@@ -3,13 +3,13 @@
 import logging
 import threading
 
-from autobahn.twisted.websocket import WebSocketClientFactory
-from autobahn.twisted.websocket import WebSocketClientProtocol
-from autobahn.twisted.websocket import connectWS
+from autobahn.twisted.websocket import (
+    WebSocketClientFactory,
+    WebSocketClientProtocol,
+    connectWS,
+)
 from autobahn.websocket.util import create_url
-from twisted.internet import defer
-from twisted.internet import reactor
-from twisted.internet import threads
+from twisted.internet import defer, reactor, threads
 from twisted.internet.protocol import ReconnectingClientFactory
 from twisted.python import log
 

src/roslibpy/comm/comm_cli.py

@@ -3,32 +3,29 @@
 import logging
 import math
 
-from System import Action
-from System import Array
-from System import ArraySegment
-from System import Byte
-from System import TimeSpan
-from System import Uri
-from System import UriBuilder
-from System.Net.WebSockets import ClientWebSocket
-from System.Net.WebSockets import WebSocketCloseStatus
-from System.Net.WebSockets import WebSocketError
-from System.Net.WebSockets import WebSocketMessageType
-from System.Net.WebSockets import WebSocketReceiveResult
-from System.Net.WebSockets import WebSocketState
+from System import Action, Array, ArraySegment, Byte, TimeSpan, Uri, UriBuilder
+from System.Net.WebSockets import (
+    ClientWebSocket,
+    WebSocketCloseStatus,
+    WebSocketError,
+    WebSocketMessageType,
+    WebSocketReceiveResult,
+    WebSocketState,
+)
 from System.Text import Encoding
-from System.Threading import CancellationToken
-from System.Threading import CancellationTokenSource
-from System.Threading import ManualResetEventSlim
-from System.Threading import SemaphoreSlim
-from System.Threading import Thread
-from System.Threading import ThreadPool
-from System.Threading import WaitCallback
+from System.Threading import (
+    CancellationToken,
+    CancellationTokenSource,
+    ManualResetEventSlim,
+    SemaphoreSlim,
+    Thread,
+    ThreadPool,
+    WaitCallback,
+)
 from System.Threading.Tasks import Task
 
 from ..event_emitter import EventEmitterMixin
-from . import RosBridgeException
-from . import RosBridgeProtocol
+from . import RosBridgeException, RosBridgeProtocol
 
 LOGGER = logging.getLogger('roslibpy')
 RECEIVE_CHUNK_SIZE = 1024

src/roslibpy/core.py

@@ -130,7 +130,7 @@ class Topic(object):
         queue_size (:obj:`int`): Queue size created at bridge side for re-publishing webtopics.
         latch (:obj:`bool`): True to latch the topic when publishing, False otherwise.
         queue_length (:obj:`int`): Queue length at bridge side used when subscribing.
-        reconnect_on_close (:obj:`bool`): Reconnect the topic (both for publisher and subscribers) if a reconnection is detected.
+        reconnect_on_close (:obj:`bool`): Reconnect topic (both publisher & subscriber) on reconnection.
     """
 
     SUPPORTED_COMPRESSION_TYPES = ("png", "none")

src/roslibpy/event_emitter.py

@@ -32,14 +32,12 @@
 """
 
 try:
-    from asyncio import ensure_future
-    from asyncio import iscoroutine
+    from asyncio import ensure_future, iscoroutine
 except ImportError:
     iscoroutine = None
     ensure_future = None
 
-from collections import OrderedDict
-from collections import defaultdict
+from collections import OrderedDict, defaultdict
 from threading import RLock
 
 __all__ = ["EventEmitterMixin", "EventEmitterException"]

src/roslibpy/ros.py

@@ -3,11 +3,7 @@
 import logging
 import threading
 
-from . import Message
-from . import Param
-from . import Service
-from . import ServiceRequest
-from . import Time
+from . import Message, Param, Service, ServiceRequest, Time
 from .comm import RosBridgeClientFactory
 
 __all__ = ["Ros", "set_rosapi_timeout"]

src/roslibpy/tf.py

@@ -18,9 +18,7 @@
 import logging
 import math
 
-from . import Service
-from . import ServiceRequest
-from . import Topic
+from . import Service, ServiceRequest, Topic
 
 __all__ = ["TFClient"]
 
@@ -36,7 +34,7 @@ class TFClient(object):
         angular_threshold (:obj:`float`): Angular threshold for the TF republisher.
         translation_threshold (:obj:`float`): Translation threshold for the TF republisher.
         rate (:obj:`float`): Rate for the TF republisher.
-        update_delay (:obj:`int`): Time expressed in milliseconds to wait after a new subscription to update the TF republisher's list of TFs.
+        update_delay (:obj:`int`): Time expressed in milliseconds to wait after a new subscription before update TFs.
         topic_timeout (:obj:`int`): Timeout parameter for the TF republisher expressed in milliseconds.
         repub_service_name (:obj:`str`): Name of the republish tfs service, e.g. ``/republish_tfs``.
     """