diff libervia/backend/plugins/plugin_exp_jingle_stream.py @ 4270:0d7bb4df2343

Reformatted code base using black.
author Goffi <goffi@goffi.org>
date Wed, 19 Jun 2024 18:44:57 +0200
parents 4b842c1fb686
children
line wrap: on
line diff
--- a/libervia/backend/plugins/plugin_exp_jingle_stream.py	Tue Jun 18 12:06:45 2024 +0200
+++ b/libervia/backend/plugins/plugin_exp_jingle_stream.py	Wed Jun 19 18:44:57 2024 +0200
@@ -217,17 +217,19 @@
                 factory.port_listening = port_listening
                 break
         # we don't want to wait for IQ result of initiate
-        defer.ensureDeferred(self._j.initiate(
-            client,
-            to_jid,
-            [
-                {
-                    "app_ns": NS_STREAM,
-                    "senders": self._j.ROLE_INITIATOR,
-                    "app_kwargs": {"stream_object": factory},
-                }
-            ],
-        ))
+        defer.ensureDeferred(
+            self._j.initiate(
+                client,
+                to_jid,
+                [
+                    {
+                        "app_ns": NS_STREAM,
+                        "senders": self._j.ROLE_INITIATOR,
+                        "app_kwargs": {"stream_object": factory},
+                    }
+                ],
+            )
+        )
         return str(port)
 
     def jingle_session_init(self, client, session, content_name, stream_object):
@@ -239,7 +241,9 @@
         return desc_elt
 
     @defer.inlineCallbacks
-    def jingle_request_confirmation(self, client, action, session, content_name, desc_elt):
+    def jingle_request_confirmation(
+        self, client, action, session, content_name, desc_elt
+    ):
         """This method request confirmation for a jingle session"""
         content_data = session["contents"][content_name]
         if content_data["senders"] not in (
@@ -287,7 +291,9 @@
             content_data["stream_object"] = application_data["stream_object"]
             finished_d = content_data["finished_d"] = defer.Deferred()
             args = [client, session, content_name, content_data]
-            finished_d.addCallbacks(self._finished_cb, self._finished_eb, args, None, args)
+            finished_d.addCallbacks(
+                self._finished_cb, self._finished_eb, args, None, args
+            )
         else:
             log.warning("FIXME: unmanaged action {}".format(action))
         return desc_elt