#NEWLINE# def test_filtered_channels_noblock( self ) : #NEWLINE# #INDENT# channelFilter = FilteredChannelFactory . FilteredChannel ( callbackScheduler , self . filterAllButMinId ) #NEWLINE# try : #NEWLINE# #INDENT# ( viewChannel , managerChannel ) = channelFilter . getChannelPair ( ) #NEWLINE# MessageOut = getattr ( SharedStateNative , 'SharedState::MessageOut' ) #NEWLINE# filteredMessage = MessageOut . MinimumIdResponse ( 0 ) #NEWLINE# allowedMessage = MessageOut . FlushRequest ( 0 ) #NEWLINE# viewChannel . write ( filteredMessage ) #NEWLINE# viewChannel . write ( allowedMessage ) #NEWLINE# toGet = [ None ] #NEWLINE# def tryGet( ) : #NEWLINE# #INDENT# toGet [ 0 ] = managerChannel . get ( ) #NEWLINE# #UNINDENT# t = ManagedThread . ManagedThread ( target = tryGet ) #NEWLINE# t . start ( ) #NEWLINE# t . join ( 4 ) #NEWLINE# self . assertIsNotNone ( managerChannel [ 0 ] ) #NEWLINE# #UNINDENT# finally : #NEWLINE# #INDENT# channelFilter . teardown ( )