#NEWLINE# def join( self , uri ) : #NEWLINE# #INDENT# 'docstring for join' #NEWLINE# ( _schema , peer_id ) = uri . split ( ':' ) #NEWLINE# if ( peer_id not in factories ) : #NEWLINE# #INDENT# raise Exception ( 'FAKE trying to join not existing peer' ) #NEWLINE# #UNINDENT# tp = FakeTransport ( self . _rt_id , _schema , uri , { #NEWLINE# #INDENT# 'data_received' : self . callbacks [ 'data_received' ] , #NEWLINE# #UNINDENT# } ) #NEWLINE# self . peers [ peer_id ] = tp #NEWLINE# ptp = factories [ peer_id ] . _joined ( self . _rt_id , tp , ( 'fake_transport:' + self . _rt_id ) ) #NEWLINE# tp . _set_peer ( ptp ) #NEWLINE# self . _callback_execute ( 'join_finished' , tp , peer_id , uri )