#NEWLINE# def test_create_blob_from_stream_chunked_upload_parallel( self ) : #NEWLINE# #INDENT# if TestMode . need_recording_file ( self . test_mode ) : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# blob_name = self . _get_blob_reference ( ) #NEWLINE# data = self . get_random_bytes ( LARGE_BLOB_SIZE ) #NEWLINE# with open ( FILE_PATH , 'wb' ) as stream : #NEWLINE# #INDENT# stream . write ( data ) #NEWLINE# #UNINDENT# blob_size = len ( data ) #NEWLINE# with open ( FILE_PATH , 'rb' ) as stream : #NEWLINE# #INDENT# self . bs . create_blob_from_stream ( self . container_name , blob_name , self , blob_size , max_connections = 5 ) #NEWLINE# #UNINDENT# self . assertBlobEqual ( self . container_name , blob_name , data [ : blob_size ] )