File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1919# endregion same code as other examples
2020
2121from openlcb import precise_sleep # noqa: E402
22- from openlcb .canbus .gridconnectobserver import GridConnectObserver # noqa:E402
2322from openlcb .tcplink .tcpsocket import TcpSocket # noqa: E402
2423from openlcb .canbus .canphysicallayergridconnect import ( # noqa: E402
2524 CanPhysicalLayerGridConnect ,
@@ -80,8 +79,6 @@ def handleDisconnect():
8079physicalLayer .sendFrameAfter (frame )
8180physicalLayer .sendAll (sock , verbose = True )
8281
83- observer = GridConnectObserver ()
84-
8582# display response - should be RID from nodes
8683while True :
8784 count = physicalLayer .receiveAll (sock , verbose = True )
Original file line number Diff line number Diff line change 2020# endregion same code as other examples
2121
2222from openlcb import precise_sleep # noqa: E402
23- from openlcb .canbus .gridconnectobserver import GridConnectObserver # noqa:E402
2423from openlcb .tcplink .tcpsocket import TcpSocket # noqa: E402
2524
2625from openlcb .canbus .canphysicallayergridconnect import ( # noqa: E402
@@ -160,8 +159,6 @@ def displayOtherNodeIds(message) :
160159 NodeID (settings ['localNodeID' ]), None )
161160canLink .sendMessage (message )
162161
163- observer = GridConnectObserver ()
164-
165162# process resulting activity
166163while True :
167164 count = 0
Original file line number Diff line number Diff line change 1414from timeit import default_timer
1515from examples_settings import Settings # do 1st to fix path if no pip install
1616from openlcb import precise_sleep
17- from openlcb .canbus .gridconnectobserver import GridConnectObserver
1817settings = Settings ()
1918
2019if __name__ == "__main__" :
@@ -106,7 +105,6 @@ def printMessage(msg):
106105
107106readQueue = Queue ()
108107
109- observer = GridConnectObserver ()
110108_frameReceivedListeners = physicalLayer ._frameReceivedListeners
111109assert len (_frameReceivedListeners ) == 1 , \
112110 "{} listener(s) unexpectedly" .format (len (_frameReceivedListeners ))
You can’t perform that action at this time.
0 commit comments