File tree Expand file tree Collapse file tree 3 files changed +0
-94
lines changed Expand file tree Collapse file tree 3 files changed +0
-94
lines changed Original file line number Diff line number Diff line change @@ -17,7 +17,6 @@ def __init__(self):
1717        self .hub  =  MessageHub ()
1818        self .ws  =  WebSocketStreamer (self .hub )
1919
20- 
2120        self .add_service (self .hub )
2221        self .add_service (self .ws )
2322        self .add_service (self .client )
  Load Diff This file was deleted. 
Original file line number Diff line number Diff line change 33
44from  .http  import  HttpStreamer 
55from  .http  import  HttpTailViewer 
6- from  .websocket  import  WebSocketStreamer 
76
87class  Subscription (gevent .queue .Queue ):
98    def  __init__ (self , channel ):
@@ -19,7 +18,6 @@ def __init__(self):
1918
2019        self .add_service (HttpStreamer (self ))
2120        self .add_service (HttpTailViewer (self ))
22-         self .add_service (WebSocketStreamer (self ))
2321
2422    def  publish (self , channel , message ):
2523        for  subscription  in  self .subscriptions .get (channel , []):
    
 
   
 
     
   
   
          
     
  
    
     
 
    
      
     
 
     
    You can’t perform that action at this time.
  
 
    
  
     
    
      
        
     
 
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments