 from . . core import Observable <EOL> class PubnubMock ( Observable ) : <EOL> def __init__ ( self ) : <EOL> Observable . __init__ ( self ) <EOL> def subscribe ( self , channel , callback = None , error = None , connect = None , reconnect = None , disconnect = None ) : <EOL> self . on ( '<STR_LIT:message>' , callback ) 
 def unsubscribe ( self , channel ) : 
 from . . core import Observable <EOL> class PubnubMock ( Observable ) : <EOL> def __init__ ( self ) : <EOL> Observable . __init__ ( self ) <EOL> def subscribe ( self , channel , callback = None , error = None , connect = None , reconnect = None , disconnect = None ) : <EOL> self . on ( '<STR_LIT:message>' , callback ) <EOL> def unsubscribe ( self , channel ) : <EOL> pass <EOL> def receive_message ( self , message ) : <EOL> self . emit ( '<STR_LIT:message>' , message ) </s>
