#NEWLINE# def test_server( self ) : #NEWLINE# #INDENT# server_data = self . stream . get_epoch_iterator ( ) #NEWLINE# expected_data = get_stream ( ) . get_epoch_iterator ( ) #NEWLINE# for ( _ , s , e ) in zip ( range ( 3 ) , server_data , expected_data ) : #NEWLINE# #INDENT# for data in zip ( s , e ) : #NEWLINE# #INDENT# assert_allclose ( * data ) #NEWLINE# #UNINDENT# #UNINDENT# assert_raises ( StopIteration , next , server_data )