#NEWLINE# def test_subscribe( self ) : #NEWLINE# #INDENT# cbmock = Mock ( ) #NEWLINE# sub = Subscriber ( node = self . _node , from_name = 'testsub' , callback = cbmock ) #NEWLINE# listen_channel_mock = self . _setup_mock_channel ( ch_type = SubscriberChannel , value = 'subbed' , error_message = '' ) #NEWLINE# sub . node . channel . return_value = listen_channel_mock #NEWLINE# listen_channel_mock . accept . return_value = listen_channel_mock #NEWLINE# sub . listen ( ) #NEWLINE# cbmock . assert_called_once_with ( 'subbed' , { #NEWLINE# #INDENT# 'conv-id' : sentinel . conv_id , #NEWLINE# 'status_code' : 200 , #NEWLINE# 'error_message' : '' , #NEWLINE# 'op' : None , #NEWLINE# #UNINDENT# } )