cores/i2c/stream: create i2c stream description

Author: povauboin

lambdalib/cores/i2c/stream.py

@@ -10,10 +10,15 @@
     "I2CStream",
     "I2CWriterStream",
     "I2CRegStream",
+    "i2c_stream_description",
     "i2c_writer_description",
 ]
 
 
+i2c_stream_description = [
+    ("r_wn", 1),
+    ("data", 8),
+]
 i2c_writer_description = [
     ("data", 8),
 ]
@@ -108,11 +113,8 @@ def __init__(self, pins, period_cyc, **kwargs):
         self.period_cyc = period_cyc
         self.kwargs = kwargs
 
-        self.error = Signal()
-        self.sink = stream.Endpoint([
-            ("r_wn", 1),
-            ("data", 8),
-        ])
+        self.error  = Signal()
+        self.sink   = stream.Endpoint(i2c_stream_description)
         self.source = stream.Endpoint([
             ("data", 8),
         ])

lambdalib/cores/lcd/ssd1306.py

@@ -5,6 +5,7 @@
 from ...interface import stream
 from ...interface.stream_utils import *
 from ..mem.stream import *
+from ..i2c.stream import *
 
 
 __all__ = ["SSD1306"]
@@ -43,10 +44,7 @@ def __init__(self):
             ("d_cn", 1),
             ("data", 8),
         ])
-        self.source = stream.Endpoint([
-            ("r_wn", 1),
-            ("data", 8),
-        ])
+        self.source = stream.Endpoint(i2c_stream_description)
 
     def elaborate(self, platform):
         sink = self.sink
@@ -132,15 +130,8 @@ def __init__(self, width, height, por_init=True):
         self.reset = Signal()
         self.ready = Signal()
 
-        self.sink = stream.Endpoint([
-            ("data", 8),
-        ])
-        # I2CStream interface
-        self.source = stream.Endpoint([
-            ("r_wn", 1),
-            ("data", 8),
-        ])
-        self.error = Signal()
+        self.sink   = stream.Endpoint([("data", 8)])
+        self.source = stream.Endpoint(i2c_stream_description)
 
     def elaborate(self, platform):
         sink = self.sink