projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Apply black code formatter on all Python code
[babeltrace.git]
/
tests
/
bindings
/
python
/
bt2
/
test_connection.py
diff --git
a/tests/bindings/python/bt2/test_connection.py
b/tests/bindings/python/bt2/test_connection.py
index 7c1cbe5715de45e2e2d8e61dd064ab0930c6eba0..686a75f7b2863e9cacb334f512437c3fd4adeba9 100644
(file)
--- a/
tests/bindings/python/bt2/test_connection.py
+++ b/
tests/bindings/python/bt2/test_connection.py
@@
-26,8
+26,7
@@
class ConnectionTestCase(unittest.TestCase):
def __next__(self):
raise bt2.Stop
def __next__(self):
raise bt2.Stop
- class MySource(bt2._UserSourceComponent,
- message_iterator_class=MyIter):
+ class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
def __init__(self, params):
self._add_output_port('out')
def __init__(self, params):
self._add_output_port('out')
@@
-44,8
+43,7
@@
class ConnectionTestCase(unittest.TestCase):
graph = bt2.Graph()
src = graph.add_component(MySource, 'src')
sink = graph.add_component(MySink, 'sink')
graph = bt2.Graph()
src = graph.add_component(MySource, 'src')
sink = graph.add_component(MySink, 'sink')
- conn = graph.connect_ports(src.output_ports['out'],
- sink.input_ports['in'])
+ conn = graph.connect_ports(src.output_ports['out'], sink.input_ports['in'])
self.assertIsInstance(conn, bt2._Connection)
def test_downstream_port(self):
self.assertIsInstance(conn, bt2._Connection)
def test_downstream_port(self):
@@
-53,8
+51,7
@@
class ConnectionTestCase(unittest.TestCase):
def __next__(self):
raise bt2.Stop
def __next__(self):
raise bt2.Stop
- class MySource(bt2._UserSourceComponent,
- message_iterator_class=MyIter):
+ class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
def __init__(self, params):
self._add_output_port('out')
def __init__(self, params):
self._add_output_port('out')
@@
-71,8
+68,7
@@
class ConnectionTestCase(unittest.TestCase):
graph = bt2.Graph()
src = graph.add_component(MySource, 'src')
sink = graph.add_component(MySink, 'sink')
graph = bt2.Graph()
src = graph.add_component(MySource, 'src')
sink = graph.add_component(MySink, 'sink')
- conn = graph.connect_ports(src.output_ports['out'],
- sink.input_ports['in'])
+ conn = graph.connect_ports(src.output_ports['out'], sink.input_ports['in'])
self.assertEqual(conn.downstream_port.addr, sink.input_ports['in'].addr)
def test_upstream_port(self):
self.assertEqual(conn.downstream_port.addr, sink.input_ports['in'].addr)
def test_upstream_port(self):
@@
-80,8
+76,7
@@
class ConnectionTestCase(unittest.TestCase):
def __next__(self):
raise bt2.Stop
def __next__(self):
raise bt2.Stop
- class MySource(bt2._UserSourceComponent,
- message_iterator_class=MyIter):
+ class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
def __init__(self, params):
self._add_output_port('out')
def __init__(self, params):
self._add_output_port('out')
@@
-98,6
+93,5
@@
class ConnectionTestCase(unittest.TestCase):
graph = bt2.Graph()
src = graph.add_component(MySource, 'src')
sink = graph.add_component(MySink, 'sink')
graph = bt2.Graph()
src = graph.add_component(MySource, 'src')
sink = graph.add_component(MySink, 'sink')
- conn = graph.connect_ports(src.output_ports['out'],
- sink.input_ports['in'])
+ conn = graph.connect_ports(src.output_ports['out'], sink.input_ports['in'])
self.assertEqual(conn.upstream_port.addr, src.output_ports['out'].addr)
self.assertEqual(conn.upstream_port.addr, src.output_ports['out'].addr)
This page took
0.023908 seconds
and
4
git commands to generate.