File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -115,11 +115,11 @@ def _close(self):
115115 self ._channel .stop_consuming ()
116116 self ._channel .close ()
117117 except Exception as e :
118- print (e )
118+ print (e , flush = True )
119119 try :
120120 self ._conn .close ()
121121 except Exception as e :
122- print (e )
122+ print (e , flush = True )
123123 self ._conn = None
124124 return True
125125 return False
Original file line number Diff line number Diff line change @@ -54,7 +54,7 @@ def _connect(self):
5454 self .bindRoutes ()
5555 self ._isOpen = True
5656 self ._isReady = True
57- print ("Listening on port" , self ._port )
57+ print ("Listening on port" , self ._port , flush = True )
5858 self ._server .run (port = self ._port , host = "0.0.0.0" )
5959
6060 def _close (self ):
Original file line number Diff line number Diff line change 1414from servc .config import port as default_port
1515
1616blankEmitFunction : EmitFunction = lambda route , message , code : None
17- blankOnConsuming : OnConsuming = lambda route : None
17+ blankOnConsuming : OnConsuming = lambda route : print (
18+ "Consuming on route " , route , flushh = True
19+ )
1820
1921
2022def compose_components (
You can’t perform that action at this time.
0 commit comments