diff --git a/docs/latest/google.resumable_media.requests.html b/docs/latest/google.resumable_media.requests.html index 87c24c32..e994d61f 100644 --- a/docs/latest/google.resumable_media.requests.html +++ b/docs/latest/google.resumable_media.requests.html @@ -808,8 +808,17 @@

Resumable Uploads
-initiate(transport, stream, metadata, content_type)
+initiate(transport, stream, metadata, content_type, total_bytes=None, stream_final=True)

Initiate a resumable upload.

+

By default, this method assumes your stream is in a “final” +state ready to transmit. However, stream_final=False can be used +to indicate that the size of the resource is not known. This can happen +if bytes are being dynamically fed into stream, e.g. if the stream +is attached to application logs.

+

If stream_final=False is used, chunk_size bytes will be +read from the stream every time transmit_next_chunk() is called. +If one of those reads produces strictly fewer bites than the chunk +size, the upload will be concluded.

@@ -824,6 +833,13 @@

Resumable Uploadsstr) – The content type of the resource, e.g. a JPEG image has content type image/jpeg. +
  • total_bytes (Optional [ int ]) – The total number of bytes to be +uploaded. If specified, the upload size will not be +determined from the stream (even if stream_final=True).
    • +
  • stream_final (Optional [ bool ]) – Indicates if the stream is +“final” (i.e. no more bytes will be added to it). In this case +we determine the upload size from the size of the stream. If +total_bytes is passed, this argument will be ignored.
    • @@ -879,12 +895,22 @@

    Resumable Uploads total_bytes

    Optional [ int ] – The total number of bytes to be uploaded.

    +

    If this upload is initiated (via initiate()) with +stream_final=True, this value will be populated based on the size +of the stream being uploaded. (By default stream_final=True.)

    +

    If this upload is initiated with stream_final=False, +total_bytes will be None since it cannot be +determined from the stream.

    transmit_next_chunk(transport)

    Transmit the next chunk of the resource to be uploaded.

    +

    If the current upload was initiated with stream_final=False, +this method will dynamically determine if the upload has completed. +The upload will be considered complete if the stream produces +fewer than chunk_size bytes when a chunk is read from it.

    In the case of failure, an exception is thrown that preserves the failed response:

    >>> error = None
diff --git a/docs/latest/google.resumable_media.requests.upload.html b/docs/latest/google.resumable_media.requests.upload.html
index dda4c58d..8046a4aa 100644
--- a/docs/latest/google.resumable_media.requests.upload.html
+++ b/docs/latest/google.resumable_media.requests.upload.html
@@ -295,8 +295,17 @@
 
 
    
 
    
-initiate(transport, stream, metadata, content_type)
    
+initiate(transport, stream, metadata, content_type, total_bytes=None, stream_final=True)
 
    Initiate a resumable upload.
    
+
    By default, this method assumes your stream is in a “final”
+state ready to transmit. However, stream_final=False can be used
+to indicate that the size of the resource is not known. This can happen
+if bytes are being dynamically fed into stream, e.g. if the stream
+is attached to application logs.
    
+
    If stream_final=False is used, chunk_size bytes will be
+read from the stream every time transmit_next_chunk() is called.
+If one of those reads produces strictly fewer bites than the chunk
+size, the upload will be concluded.

    @@ -311,6 +320,13 @@ ACL list.
  • content_type (str) – The content type of the resource, e.g. a JPEG image has content type image/jpeg.
    • +
  • total_bytes (Optional [ int ]) – The total number of bytes to be +uploaded. If specified, the upload size will not be +determined from the stream (even if stream_final=True).
    • +
  • stream_final (Optional [ bool ]) – Indicates if the stream is +“final” (i.e. no more bytes will be added to it). In this case +we determine the upload size from the size of the stream. If +total_bytes is passed, this argument will be ignored.
    • @@ -366,12 +382,22 @@
    total_bytes

    Optional [ int ] – The total number of bytes to be uploaded.

    +

    If this upload is initiated (via initiate()) with +stream_final=True, this value will be populated based on the size +of the stream being uploaded. (By default stream_final=True.)

    +

    If this upload is initiated with stream_final=False, +total_bytes will be None since it cannot be +determined from the stream.

    transmit_next_chunk(transport)

    Transmit the next chunk of the resource to be uploaded.

    +

    If the current upload was initiated with stream_final=False, +this method will dynamically determine if the upload has completed. +The upload will be considered complete if the stream produces +fewer than chunk_size bytes when a chunk is read from it.

    In the case of failure, an exception is thrown that preserves the failed response:

    >>> error = None
diff --git a/docs/latest/searchindex.js b/docs/latest/searchindex.js
index e9459c10..da8692e2 100644
--- a/docs/latest/searchindex.js
+++ b/docs/latest/searchindex.js
@@ -1 +1 @@
-Search.setIndex({docnames:["google.resumable_media.constants","google.resumable_media.exceptions","google.resumable_media.requests","google.resumable_media.requests.download","google.resumable_media.requests.upload","index"],envversion:51,filenames:["google.resumable_media.constants.rst","google.resumable_media.exceptions.rst","google.resumable_media.requests.rst","google.resumable_media.requests.download.rst","google.resumable_media.requests.upload.rst","index.rst"],objects:{"google.resumable_media":{constants:[0,0,0,"-"],exceptions:[1,0,0,"-"],requests:[2,0,0,"-"]},"google.resumable_media.constants":{PERMANENT_REDIRECT:[0,1,1,""],TOO_MANY_REQUESTS:[0,1,1,""],UPLOAD_CHUNK_SIZE:[0,1,1,""]},"google.resumable_media.exceptions":{InvalidResponse:[1,2,1,""]},"google.resumable_media.exceptions.InvalidResponse":{args:[1,3,1,""],response:[1,3,1,""],with_traceback:[1,4,1,""]},"google.resumable_media.requests":{ChunkedDownload:[2,5,1,""],Download:[2,5,1,""],MultipartUpload:[2,5,1,""],ResumableUpload:[2,5,1,""],SimpleUpload:[2,5,1,""],download:[3,0,0,"-"],upload:[4,0,0,"-"]},"google.resumable_media.requests.ChunkedDownload":{bytes_downloaded:[2,3,1,""],chunk_size:[2,3,1,""],consume_next_chunk:[2,4,1,""],end:[2,3,1,""],finished:[2,3,1,""],invalid:[2,3,1,""],media_url:[2,3,1,""],start:[2,3,1,""],total_bytes:[2,3,1,""]},"google.resumable_media.requests.Download":{consume:[2,4,1,""],end:[2,3,1,""],finished:[2,3,1,""],media_url:[2,3,1,""],start:[2,3,1,""]},"google.resumable_media.requests.MultipartUpload":{finished:[2,3,1,""],transmit:[2,4,1,""],upload_url:[2,3,1,""]},"google.resumable_media.requests.ResumableUpload":{bytes_uploaded:[2,3,1,""],chunk_size:[2,3,1,""],finished:[2,3,1,""],initiate:[2,4,1,""],invalid:[2,3,1,""],recover:[2,4,1,""],resumable_url:[2,3,1,""],total_bytes:[2,3,1,""],transmit_next_chunk:[2,4,1,""],upload_url:[2,3,1,""]},"google.resumable_media.requests.SimpleUpload":{finished:[2,3,1,""],transmit:[2,4,1,""],upload_url:[2,3,1,""]},"google.resumable_media.requests.download":{ChunkedDownload:[3,5,1,""],Download:[3,5,1,""]},"google.resumable_media.requests.download.ChunkedDownload":{bytes_downloaded:[3,3,1,""],chunk_size:[3,3,1,""],consume_next_chunk:[3,4,1,""],end:[3,3,1,""],finished:[3,3,1,""],invalid:[3,3,1,""],media_url:[3,3,1,""],start:[3,3,1,""],total_bytes:[3,3,1,""]},"google.resumable_media.requests.download.Download":{consume:[3,4,1,""],end:[3,3,1,""],finished:[3,3,1,""],media_url:[3,3,1,""],start:[3,3,1,""]},"google.resumable_media.requests.upload":{MultipartUpload:[4,5,1,""],ResumableUpload:[4,5,1,""],SimpleUpload:[4,5,1,""]},"google.resumable_media.requests.upload.MultipartUpload":{finished:[4,3,1,""],transmit:[4,4,1,""],upload_url:[4,3,1,""]},"google.resumable_media.requests.upload.ResumableUpload":{bytes_uploaded:[4,3,1,""],chunk_size:[4,3,1,""],finished:[4,3,1,""],initiate:[4,4,1,""],invalid:[4,3,1,""],recover:[4,4,1,""],resumable_url:[4,3,1,""],total_bytes:[4,3,1,""],transmit_next_chunk:[4,4,1,""],upload_url:[4,3,1,""]},"google.resumable_media.requests.upload.SimpleUpload":{finished:[4,3,1,""],transmit:[4,4,1,""],upload_url:[4,3,1,""]},google:{resumable_media:[5,0,0,"-"]}},objnames:{"0":["py","module","Python module"],"1":["py","data","Python data"],"2":["py","exception","Python exception"],"3":["py","attribute","Python attribute"],"4":["py","method","Python method"],"5":["py","class","Python class"]},objtypes:{"0":"py:module","1":"py:data","2":"py:exception","3":"py:attribute","4":"py:method","5":"py:class"},terms:{"1gb":2,"1mb":2,"4pb4caq":2,"50mb":2,"byte":[2,3,4],"case":[2,4],"class":[1,2,3,4],"default":[2,3],"final":2,"import":2,"int":[0,2,3,4],"public":5,"return":[1,2,3,4],"short":2,"true":2,"try":[2,4],For:[0,2],GCS:2,QPS:2,The:[1,2,3,4],These:[2,4],Useful:0,Using:[2,4],__traceback__:1,_download:[2,3],_helper:[2,3,4],_upload:[2,4],abcdef189xy_super_seri:2,abl:[2,3],about:2,accept:2,access:2,achiev:2,acl:[2,4],actual:2,added:0,addit:2,after:2,again:[2,4],all:[0,2,4],allow:2,along:2,alreadi:[2,3],also:[2,4],alt:2,among:2,ani:2,api:[2,3,4],arg:1,argument:[1,2],assign:[2,4],associ:2,assum:2,auth:2,authent:[2,3,4],authorizedsess:2,avoid:2,base:[0,1,2,3,4],basic:2,been:[0,2,3,4],befor:[2,4],begin:[2,3,4],being:2,best:2,big:2,blob_nam:2,bool:[2,3,4],both:[2,4],bucket:2,bytes_download:[2,3],bytes_upload:[2,4],bytesio:2,call:[2,3,4],caller:2,can:[0,2,3,4],cannot:2,caught_exc:[2,4],caus:[1,2],chang:2,check:2,chunk:[0,3,4],chunk_siz:[2,3,4],chunkeddownload:[2,3],client:[0,2],cloud:2,code:[0,2,4],color:2,com:2,come:[0,2],complet:[0,2,3,4],concaten:[2,3],connect:2,consid:2,construct:2,consum:[2,3],consume_next_chunk:[2,3],contain:[2,3,4,5],content:4,content_typ:[2,4],contenttyp:2,contrast:2,correct:1,cours:2,creat:2,credenti:2,current:[2,3,4],custom:1,data:[2,3,4],determin:[2,4],deviat:2,devstorag:2,disk:2,doesn:2,done:[2,4],download:[0,1,5],drop:2,due:[2,4],each:[2,3,4,5],enclos:2,encrypt:[2,3,4],end:[2,3],error:[1,2,4],essenti:2,even:2,except:[2,4,5],expect:[2,3,4],extra:[2,3,4],fail:[2,3,4],failur:[1,2,4],fals:2,file:[2,3,4],finish:[2,3,4],first:[2,3],fit:2,flag:[2,3,4],fly:2,format:2,from:[2,3,4],fulfil:[2,4],gener:[0,2,5],get:[2,4],googleapi:2,grurpl:2,gupload:2,has:[0,2,3,4,5],have:[2,3,4],header:[2,3,4],helper:[2,3],here:4,how:2,howev:[2,3],http:[0,1,2,3,4],httpstatu:[2,4],imag:[2,4],implement:2,indic:[0,2,3,4],inform:0,initi:[2,4],input:2,instanc:2,intend:2,interfac:[2,5],internet:2,invalid:[2,3,4],invalidrespons:[1,2,4],jpeg:[2,4],json:2,json_respons:2,kei:[2,3],know:2,known:2,larg:2,last:[2,3],latenc:2,len:2,length:2,let:2,librari:[2,5],like:[2,3,4],limit:[0,2],list:[2,4],live:2,locat:2,m0xlesx9:2,mai:2,major:5,make:[2,3,4],manag:[2,3],map:[2,3,4],md5hash:2,media:[0,2,3,4,5],media_url:[2,3],memori:2,metadata:[2,4],method:[2,4],modul:5,more:[0,2],much:2,multi:2,multipart:4,multipartupload:[2,4],multipl:[0,2,4],must:[0,2,4],name:2,need:0,neg:[2,3],neither:[2,3],next:[2,3,4],none:[1,2,3,4],nor:[2,3],number:[2,3,4],object:[1,2,3,4],obtain:2,occur:[2,3,4],onc:2,one:[2,4],onli:2,option:[2,3,4],other:2,out:2,over:2,packag:5,parallel:2,paramet:[1,2,3,4],part:2,pass:1,payload:4,perman:0,permanent_redirect:0,pip:5,plain:2,poor:2,portion:2,posit:[1,2],practic:2,preserv:[2,4],progress:[2,4],provid:[2,3],purpos:5,python:0,rais:[2,3,4],rang:[2,3],rare:2,rate:0,rather:2,raw:2,read:2,read_onli:2,recov:[2,4],redirect:0,reduc:2,request:5,requestsmixin:[2,3,4],requir:2,resouc:2,resourc:[2,3,4],respons:[1,2,3,4],response0:2,response1:2,response2:2,resum:[0,4,5],resumable_url:[2,4],resumableupload:[2,4],retriev:[2,3],rfc:0,ro_scop:2,same:2,scope:2,second:2,see:[0,2],seek:2,self:1,send:[2,4],sens:2,sent:[2,3,4],seri:2,server:[2,4],servic:0,session:[2,3,4],set:1,should:[2,3,4],similar:2,simpl:4,simplest:2,simpleupload:[2,4],singl:[2,4],size:[2,4],slice:[2,3],small:[2,4],smdii:2,some:[0,2,5],specif:5,specifi:[2,3],speed:2,start:[2,3],state:[1,2,3,4],statu:[0,2,4],storag:2,str:[2,3,4],stream:[2,3,4],sub:2,support:[2,3,4],sure:[2,4],tailor:5,take:2,task:2,tell:[2,4],text:2,than:2,thei:[2,3],thi:[2,3,4,5],thing:2,three:2,thrown:[2,4],too:2,too_many_request:0,total:[2,3,4],total_byt:[2,3,4],tr_request:2,transmit:[2,4],transmit_next_chunk:[2,4],transport:[3,4,5],tupl:1,two:2,type:[1,2,3,4],typic:[1,2,3],unknown:2,until:[2,4],upgrad:5,upload:[0,1,5],upload_chunk_s:[0,2,4],upload_id:2,upload_url:[2,4],uploadid:2,uploadtyp:2,url:[2,3,4],url_templ:2,usag:[2,3],use:2,used:[0,2,3,4],user:[2,4],uses:[2,5],using:2,util:[2,5],valid:[2,4],valueerror:[2,3,4],veri:2,verifi:[2,4],well:2,when:[2,4],where:[2,4],which:[1,2,3,4],with_traceback:1,without:2,would:2,write:[2,3],written:2,www:2},titles:["google.resumable_media.constants module","google.resumable_media.exceptions module","google.resumable_media.requests package","google.resumable_media.requests.download module","google.resumable_media.requests.upload module","google.resumable_media"],titleterms:{author:2,chunk:2,constant:0,content:2,download:[2,3],except:1,googl:[0,1,2,3,4,5],instal:5,modul:[0,1,2,3,4],multipart:2,packag:2,request:[2,3,4],resum:2,resumable_media:[0,1,2,3,4,5],simpl:2,submodul:2,subpackag:5,transport:2,upload:[2,4]}})
\ No newline at end of file
+Search.setIndex({docnames:["google.resumable_media.constants","google.resumable_media.exceptions","google.resumable_media.requests","google.resumable_media.requests.download","google.resumable_media.requests.upload","index"],envversion:51,filenames:["google.resumable_media.constants.rst","google.resumable_media.exceptions.rst","google.resumable_media.requests.rst","google.resumable_media.requests.download.rst","google.resumable_media.requests.upload.rst","index.rst"],objects:{"google.resumable_media":{constants:[0,0,0,"-"],exceptions:[1,0,0,"-"],requests:[2,0,0,"-"]},"google.resumable_media.constants":{PERMANENT_REDIRECT:[0,1,1,""],TOO_MANY_REQUESTS:[0,1,1,""],UPLOAD_CHUNK_SIZE:[0,1,1,""]},"google.resumable_media.exceptions":{InvalidResponse:[1,2,1,""]},"google.resumable_media.exceptions.InvalidResponse":{args:[1,3,1,""],response:[1,3,1,""],with_traceback:[1,4,1,""]},"google.resumable_media.requests":{ChunkedDownload:[2,5,1,""],Download:[2,5,1,""],MultipartUpload:[2,5,1,""],ResumableUpload:[2,5,1,""],SimpleUpload:[2,5,1,""],download:[3,0,0,"-"],upload:[4,0,0,"-"]},"google.resumable_media.requests.ChunkedDownload":{bytes_downloaded:[2,3,1,""],chunk_size:[2,3,1,""],consume_next_chunk:[2,4,1,""],end:[2,3,1,""],finished:[2,3,1,""],invalid:[2,3,1,""],media_url:[2,3,1,""],start:[2,3,1,""],total_bytes:[2,3,1,""]},"google.resumable_media.requests.Download":{consume:[2,4,1,""],end:[2,3,1,""],finished:[2,3,1,""],media_url:[2,3,1,""],start:[2,3,1,""]},"google.resumable_media.requests.MultipartUpload":{finished:[2,3,1,""],transmit:[2,4,1,""],upload_url:[2,3,1,""]},"google.resumable_media.requests.ResumableUpload":{bytes_uploaded:[2,3,1,""],chunk_size:[2,3,1,""],finished:[2,3,1,""],initiate:[2,4,1,""],invalid:[2,3,1,""],recover:[2,4,1,""],resumable_url:[2,3,1,""],total_bytes:[2,3,1,""],transmit_next_chunk:[2,4,1,""],upload_url:[2,3,1,""]},"google.resumable_media.requests.SimpleUpload":{finished:[2,3,1,""],transmit:[2,4,1,""],upload_url:[2,3,1,""]},"google.resumable_media.requests.download":{ChunkedDownload:[3,5,1,""],Download:[3,5,1,""]},"google.resumable_media.requests.download.ChunkedDownload":{bytes_downloaded:[3,3,1,""],chunk_size:[3,3,1,""],consume_next_chunk:[3,4,1,""],end:[3,3,1,""],finished:[3,3,1,""],invalid:[3,3,1,""],media_url:[3,3,1,""],start:[3,3,1,""],total_bytes:[3,3,1,""]},"google.resumable_media.requests.download.Download":{consume:[3,4,1,""],end:[3,3,1,""],finished:[3,3,1,""],media_url:[3,3,1,""],start:[3,3,1,""]},"google.resumable_media.requests.upload":{MultipartUpload:[4,5,1,""],ResumableUpload:[4,5,1,""],SimpleUpload:[4,5,1,""]},"google.resumable_media.requests.upload.MultipartUpload":{finished:[4,3,1,""],transmit:[4,4,1,""],upload_url:[4,3,1,""]},"google.resumable_media.requests.upload.ResumableUpload":{bytes_uploaded:[4,3,1,""],chunk_size:[4,3,1,""],finished:[4,3,1,""],initiate:[4,4,1,""],invalid:[4,3,1,""],recover:[4,4,1,""],resumable_url:[4,3,1,""],total_bytes:[4,3,1,""],transmit_next_chunk:[4,4,1,""],upload_url:[4,3,1,""]},"google.resumable_media.requests.upload.SimpleUpload":{finished:[4,3,1,""],transmit:[4,4,1,""],upload_url:[4,3,1,""]},google:{resumable_media:[5,0,0,"-"]}},objnames:{"0":["py","module","Python module"],"1":["py","data","Python data"],"2":["py","exception","Python exception"],"3":["py","attribute","Python attribute"],"4":["py","method","Python method"],"5":["py","class","Python class"]},objtypes:{"0":"py:module","1":"py:data","2":"py:exception","3":"py:attribute","4":"py:method","5":"py:class"},terms:{"1gb":2,"1mb":2,"4pb4caq":2,"50mb":2,"byte":[2,3,4],"case":[2,4],"class":[1,2,3,4],"default":[2,3,4],"final":[2,4],"import":2,"int":[0,2,3,4],"public":5,"return":[1,2,3,4],"short":2,"true":[2,4],"try":[2,4],For:[0,2],GCS:2,QPS:2,The:[1,2,3,4],These:[2,4],Useful:0,Using:[2,4],__traceback__:1,_download:[2,3],_helper:[2,3,4],_upload:[2,4],abcdef189xy_super_seri:2,abl:[2,3],about:2,accept:2,access:2,achiev:2,acl:[2,4],actual:2,added:[0,2,4],addit:2,after:2,again:[2,4],all:[0,2,4],allow:2,along:2,alreadi:[2,3],also:[2,4],alt:2,among:2,ani:2,api:[2,3,4],applic:[2,4],arg:1,argument:[1,2,4],assign:[2,4],associ:2,assum:[2,4],attach:[2,4],auth:2,authent:[2,3,4],authorizedsess:2,avoid:2,base:[0,1,2,3,4],basic:2,been:[0,2,3,4],befor:[2,4],begin:[2,3,4],being:[2,4],best:2,big:2,bite:[2,4],blob_nam:2,bool:[2,3,4],both:[2,4],bucket:2,bytes_download:[2,3],bytes_upload:[2,4],bytesio:2,call:[2,3,4],caller:2,can:[0,2,3,4],cannot:[2,4],caught_exc:[2,4],caus:[1,2],chang:2,check:2,chunk:[0,3,4],chunk_siz:[2,3,4],chunkeddownload:[2,3],client:[0,2],cloud:2,code:[0,2,4],color:2,com:2,come:[0,2],complet:[0,2,3,4],concaten:[2,3],conclud:[2,4],connect:2,consid:[2,4],construct:2,consum:[2,3],consume_next_chunk:[2,3],contain:[2,3,4,5],content:4,content_typ:[2,4],contenttyp:2,contrast:2,correct:1,cours:2,creat:2,credenti:2,current:[2,3,4],custom:1,data:[2,3,4],determin:[2,4],deviat:2,devstorag:2,disk:2,doesn:2,done:[2,4],download:[0,1,5],drop:2,due:[2,4],dynam:[2,4],each:[2,3,4,5],enclos:2,encrypt:[2,3,4],end:[2,3],error:[1,2,4],essenti:2,even:[2,4],everi:[2,4],except:[2,4,5],expect:[2,3,4],extra:[2,3,4],fail:[2,3,4],failur:[1,2,4],fals:[2,4],fed:[2,4],fewer:[2,4],file:[2,3,4],finish:[2,3,4],first:[2,3],fit:2,flag:[2,3,4],fly:2,format:2,from:[2,3,4],fulfil:[2,4],gener:[0,2,5],get:[2,4],googleapi:2,grurpl:2,gupload:2,happen:[2,4],has:[0,2,3,4,5],have:[2,3,4],header:[2,3,4],helper:[2,3],here:4,how:2,howev:[2,3,4],http:[0,1,2,3,4],httpstatu:[2,4],ignor:[2,4],imag:[2,4],implement:2,indic:[0,2,3,4],inform:0,initi:[2,4],input:2,instanc:2,intend:2,interfac:[2,5],internet:2,invalid:[2,3,4],invalidrespons:[1,2,4],jpeg:[2,4],json:2,json_respons:2,kei:[2,3],know:2,known:[2,4],larg:2,last:[2,3],latenc:2,len:2,length:2,let:2,librari:[2,5],like:[2,3,4],limit:[0,2],list:[2,4],live:2,locat:2,log:[2,4],m0xlesx9:2,mai:2,major:5,make:[2,3,4],manag:[2,3],map:[2,3,4],md5hash:2,media:[0,2,3,4,5],media_url:[2,3],memori:2,metadata:[2,4],method:[2,4],modul:5,more:[0,2,4],much:2,multi:2,multipart:4,multipartupload:[2,4],multipl:[0,2,4],must:[0,2,4],name:2,need:0,neg:[2,3],neither:[2,3],next:[2,3,4],none:[1,2,3,4],nor:[2,3],number:[2,3,4],object:[1,2,3,4],obtain:2,occur:[2,3,4],onc:2,one:[2,4],onli:2,option:[2,3,4],other:2,out:2,over:2,packag:5,parallel:2,paramet:[1,2,3,4],part:2,pass:[1,2,4],payload:4,perman:0,permanent_redirect:0,pip:5,plain:2,poor:2,popul:[2,4],portion:2,posit:[1,2],practic:2,preserv:[2,4],produc:[2,4],progress:[2,4],provid:[2,3],purpos:5,python:0,rais:[2,3,4],rang:[2,3],rare:2,rate:0,rather:2,raw:2,read:[2,4],read_onli:2,readi:[2,4],recov:[2,4],redirect:0,reduc:2,request:5,requestsmixin:[2,3,4],requir:2,resouc:2,resourc:[2,3,4],respons:[1,2,3,4],response0:2,response1:2,response2:2,resum:[0,4,5],resumable_url:[2,4],resumableupload:[2,4],retriev:[2,3],rfc:0,ro_scop:2,same:2,scope:2,second:2,see:[0,2],seek:2,self:1,send:[2,4],sens:2,sent:[2,3,4],seri:2,server:[2,4],servic:0,session:[2,3,4],set:1,should:[2,3,4],similar:2,simpl:4,simplest:2,simpleupload:[2,4],sinc:[2,4],singl:[2,4],size:[2,4],slice:[2,3],small:[2,4],smdii:2,some:[0,2,5],specif:5,specifi:[2,3,4],speed:2,start:[2,3],state:[1,2,3,4],statu:[0,2,4],storag:2,str:[2,3,4],stream:[2,3,4],stream_fin:[2,4],strictli:[2,4],sub:2,support:[2,3,4],sure:[2,4],tailor:5,take:2,task:2,tell:[2,4],text:2,than:[2,4],thei:[2,3],thi:[2,3,4,5],thing:2,those:[2,4],three:2,thrown:[2,4],time:[2,4],too:2,too_many_request:0,total:[2,3,4],total_byt:[2,3,4],tr_request:2,transmit:[2,4],transmit_next_chunk:[2,4],transport:[3,4,5],tupl:1,two:2,type:[1,2,3,4],typic:[1,2,3],unknown:2,until:[2,4],upgrad:5,upload:[0,1,5],upload_chunk_s:[0,2,4],upload_id:2,upload_url:[2,4],uploadid:2,uploadtyp:2,url:[2,3,4],url_templ:2,usag:[2,3],use:2,used:[0,2,3,4],user:[2,4],uses:[2,5],using:2,util:[2,5],valid:[2,4],valu:[2,4],valueerror:[2,3,4],veri:2,verifi:[2,4],via:[2,4],well:2,when:[2,4],where:[2,4],which:[1,2,3,4],with_traceback:1,without:2,would:2,write:[2,3],written:2,www:2,your:[2,4]},titles:["google.resumable_media.constants module","google.resumable_media.exceptions module","google.resumable_media.requests package","google.resumable_media.requests.download module","google.resumable_media.requests.upload module","google.resumable_media"],titleterms:{author:2,chunk:2,constant:0,content:2,download:[2,3],except:1,googl:[0,1,2,3,4,5],instal:5,modul:[0,1,2,3,4],multipart:2,packag:2,request:[2,3,4],resum:2,resumable_media:[0,1,2,3,4,5],simpl:2,submodul:2,subpackag:5,transport:2,upload:[2,4]}})
\ No newline at end of file
diff --git a/google/resumable_media/_upload.py b/google/resumable_media/_upload.py
index 74a23fa1..3bbe0843 100644
--- a/google/resumable_media/_upload.py
+++ b/google/resumable_media/_upload.py
@@ -38,6 +38,8 @@
 
 _CONTENT_TYPE_HEADER = u'content-type'
 _CONTENT_RANGE_TEMPLATE = u'bytes {:d}-{:d}/{:d}'
+_RANGE_UNKNOWN_TEMPLATE = u'bytes {:d}-{:d}/*'
+_EMPTY_RANGE_TEMPLATE = u'bytes */{:d}'
 _BOUNDARY_WIDTH = len(repr(sys.maxsize - 1))
 _BOUNDARY_FORMAT = u'==============={{:0{:d}d}}=='.format(_BOUNDARY_WIDTH)
 _MULTIPART_SEP = b'--'
@@ -51,6 +53,9 @@
     u'Bytes stream is in unexpected state. '
     u'The local stream has had {:d} bytes read from it while '
     u'{:d} bytes have already been updated (they should match).')
+_STREAM_READ_PAST_TEMPLATE = (
+    u'{:d} bytes have been read from the stream, which exceeds '
+    u'the expected total {:d}.')
 _POST = u'POST'
 _PUT = u'PUT'
 
@@ -127,6 +132,18 @@ def _get_headers(response):
         """
         raise NotImplementedError(u'This implementation is virtual.')
 
+    @staticmethod
+    def _get_body(response):
+        """Access the response body from an HTTP response.
+
+        Args:
+            response (object): The HTTP response object.
+
+        Raises:
+            NotImplementedError: Always, since virtual.
+        """
+        raise NotImplementedError(u'This implementation is virtual.')
+
 
 class SimpleUpload(UploadBase):
     """Upload a resource to a Google API.
@@ -336,10 +353,20 @@ def bytes_uploaded(self):
 
     @property
     def total_bytes(self):
-        """Optional[int]: The total number of bytes to be uploaded."""
+        """Optional[int]: The total number of bytes to be uploaded.
+
+        If this upload is initiated (via :meth:`initiate`) with
+        ``stream_final=True``, this value will be populated based on the size
+        of the ``stream`` being uploaded. (By default ``stream_final=True``.)
+
+        If this upload is initiated with ``stream_final=False``,
+        :attr:`total_bytes` will be :data:`None` since it cannot be
+        determined from the stream.
+        """
         return self._total_bytes
 
-    def _prepare_initiate_request(self, stream, metadata, content_type):
+    def _prepare_initiate_request(self, stream, metadata, content_type,
+                                  total_bytes=None, stream_final=True):
         """Prepare the contents of HTTP request to initiate upload.
 
         This is everything that must be done before a request that doesn't
@@ -354,6 +381,13 @@ def _prepare_initiate_request(self, stream, metadata, content_type):
                 ACL list.
             content_type (str): The content type of the resource, e.g. a JPEG
                 image has content type ``image/jpeg``.
+            total_bytes (Optional[int]): The total number of bytes to be
+                uploaded. If specified, the upload size **will not** be
+                determined from the stream (even if ``stream_final=True``).
+            stream_final (Optional[bool]): Indicates if the ``stream`` is
+                "final" (i.e. no more bytes will be added to it). In this case
+                we determine the upload size from the size of the stream. If
+                ``total_bytes`` is passed, this argument will be ignored.
 
         Returns:
             Tuple[str, str, bytes, Mapping[str, str]]: The quadruple
@@ -376,12 +410,20 @@ def _prepare_initiate_request(self, stream, metadata, content_type):
 
         self._stream = stream
         self._content_type = content_type
-        self._total_bytes = get_total_bytes(stream)
         headers = {
             _CONTENT_TYPE_HEADER: u'application/json; charset=UTF-8',
             u'x-upload-content-type': content_type,
-            u'x-upload-content-length': u'{:d}'.format(self._total_bytes),
         }
+        # Set the total bytes if possible.
+        if total_bytes is not None:
+            self._total_bytes = total_bytes
+        elif stream_final:
+            self._total_bytes = get_total_bytes(stream)
+        # Add the total bytes to the headers if set.
+        if self._total_bytes is not None:
+            content_length = u'{:d}'.format(self._total_bytes)
+            headers[u'x-upload-content-length'] = content_length
+
         headers.update(self._headers)
         payload = json.dumps(metadata).encode(u'utf-8')
         return _POST, self.upload_url, payload, headers
@@ -405,9 +447,21 @@ def _process_initiate_response(self, response):
         self._resumable_url = _helpers.header_required(
             response, u'location', self._get_headers)
 
-    def initiate(self, transport, stream, metadata, content_type):
+    def initiate(self, transport, stream, metadata, content_type,
+                 total_bytes=None, stream_final=True):
         """Initiate a resumable upload.
 
+        By default, this method assumes your ``stream`` is in a "final"
+        state ready to transmit. However, ``stream_final=False`` can be used
+        to indicate that the size of the resource is not known. This can happen
+        if bytes are being dynamically fed into ``stream``, e.g. if the stream
+        is attached to application logs.
+
+        If ``stream_final=False`` is used, :attr:`chunk_size` bytes will be
+        read from the stream every time :meth:`transmit_next_chunk` is called.
+        If one of those reads produces strictly fewer bites than the chunk
+        size, the upload will be concluded.
+
         Args:
             transport (object): An object which can make authenticated
                 requests.
@@ -418,6 +472,13 @@ def initiate(self, transport, stream, metadata, content_type):
                 ACL list.
             content_type (str): The content type of the resource, e.g. a JPEG
                 image has content type ``image/jpeg``.
+            total_bytes (Optional[int]): The total number of bytes to be
+                uploaded. If specified, the upload size **will not** be
+                determined from the stream (even if ``stream_final=True``).
+            stream_final (Optional[bool]): Indicates if the ``stream`` is
+                "final" (i.e. no more bytes will be added to it). In this case
+                we determine the upload size from the size of the stream. If
+                ``total_bytes`` is passed, this argument will be ignored.
 
         Raises:
             NotImplementedError: Always, since virtual.
@@ -464,15 +525,13 @@ def _prepare_request(self):
                 u'This upload has not been initiated. Please call '
                 u'initiate() before beginning to transmit chunks.')
 
-        start_byte, end_byte, payload = get_next_chunk(
-            self._stream, self._chunk_size)
+        start_byte, end_byte, payload, content_range = get_next_chunk(
+            self._stream, self._chunk_size, self._total_bytes)
         if start_byte != self.bytes_uploaded:
             msg = _STREAM_ERROR_TEMPLATE.format(
                 start_byte, self.bytes_uploaded)
             raise ValueError(msg)
 
-        content_range = _CONTENT_RANGE_TEMPLATE.format(
-            start_byte, end_byte, self._total_bytes)
         headers = {
             _CONTENT_TYPE_HEADER: self._content_type,
             _helpers.CONTENT_RANGE_HEADER: content_range,
@@ -511,7 +570,8 @@ def _process_response(self, response):
             response, (http_client.OK, resumable_media.PERMANENT_REDIRECT),
             self._get_status_code, callback=self._make_invalid)
         if status_code == http_client.OK:
-            self._bytes_uploaded = self._total_bytes
+            json_response = json.loads(self._get_body(response))
+            self._bytes_uploaded = int(json_response[u'size'])
             # Tombstone the current upload so it cannot be used again.
             self._finished = True
         else:
@@ -529,6 +589,11 @@ def _process_response(self, response):
     def transmit_next_chunk(self, transport):
         """Transmit the next chunk of the resource to be uploaded.
 
+        If the current upload was initiated with ``stream_final=False``,
+        this method will dynamically determine if the upload has completed.
+        The upload will be considered complete if the stream produces
+        fewer than :attr:`chunk_size` bytes when a chunk is read from it.
+
         Args:
             transport (object): An object which can make authenticated
                 requests.
@@ -695,7 +760,7 @@ def get_total_bytes(stream):
     return end_position
 
 
-def get_next_chunk(stream, chunk_size):
+def get_next_chunk(stream, chunk_size, total_bytes):
     """Get a chunk from an I/O stream.
 
     The ``stream`` may have fewer bytes remaining than ``chunk_size``
@@ -703,21 +768,72 @@ def get_next_chunk(stream, chunk_size):
     ``end_byte == start_byte + chunk_size - 1``.
 
     Args:
-       stream (IO[bytes]): The stream (i.e. file-like object).
+        stream (IO[bytes]): The stream (i.e. file-like object).
+        chunk_size (int): The size of the chunk to be read from the ``stream``.
+        total_bytes (Optional[int]): The (expected) total number of bytes
+            in the ``stream``.
 
     Returns:
-        Tuple[int, int, bytes]: Triple of the start byte index, the end byte
-        index and the content in between those bytes.
+        Tuple[int, int, bytes, str]: Quadruple of:
+
+          * the start byte index
+          * the end byte index
+          * the content in between the start and end bytes (inclusive)
+          * content range header for the chunk (slice) that has been read
 
     Raises:
         ValueError: If there is no data left to consume. This corresponds
             exactly to the case ``end_byte < start_byte``, which can only
             occur if ``end_byte == start_byte - 1``.
+        ValueError: If the stream has been read past ``total_bytes`` (this
+            is in the case that ``total_bytes`` is not :data:`None`).
     """
     start_byte = stream.tell()
     payload = stream.read(chunk_size)
     end_byte = stream.tell() - 1
-    if end_byte < start_byte:
-        raise ValueError(
-            u'Stream is already exhausted. There is no content remaining.')
-    return start_byte, end_byte, payload
+
+    num_bytes_read = len(payload)
+    if total_bytes is None:
+        if num_bytes_read < chunk_size:
+            # We now **KNOW** the total number of bytes.
+            total_bytes = end_byte + 1
+    else:
+        if num_bytes_read == 0:
+            raise ValueError(
+                u'Stream is already exhausted. There is no content remaining.')
+
+        if end_byte >= total_bytes:
+            msg = _STREAM_READ_PAST_TEMPLATE.format(end_byte + 1, total_bytes)
+            raise ValueError(msg)
+
+    content_range = get_content_range(start_byte, end_byte, total_bytes)
+    return start_byte, end_byte, payload, content_range
+
+
+def get_content_range(start_byte, end_byte, total_bytes):
+    """Convert start, end and total into content range header.
+
+    If ``total_bytes`` is not known, uses "bytes {start}-{end}/*".
+    If we are dealing with an empty range (i.e. ``end_byte < start_byte``)
+    then "bytes */{total}" is used.
+
+    This function **ASSUMES** that if the size is not known, the caller will
+    not also pass an empty range.
+
+    Args:
+        start_byte (int): The start (inclusive) of the byte range.
+        end_byte (int): The end (inclusive) of the byte range.
+        total_bytes (Optional[int]): The number of bytes in the byte
+            range (if known).
+
+    Returns:
+        str: The content range header.
+    """
+    if total_bytes is None:
+        return _RANGE_UNKNOWN_TEMPLATE.format(
+            start_byte, end_byte)
+    elif end_byte < start_byte:
+        return _EMPTY_RANGE_TEMPLATE.format(total_bytes)
+    else:
+        return _CONTENT_RANGE_TEMPLATE.format(
+            start_byte, end_byte, total_bytes)
diff --git a/google/resumable_media/requests/__init__.py b/google/resumable_media/requests/__init__.py
index 64004b2b..1258973d 100644
--- a/google/resumable_media/requests/__init__.py
+++ b/google/resumable_media/requests/__init__.py
@@ -617,6 +617,7 @@ def dont_sleep(seconds):
    payload = {
        u'bucket': bucket,
        u'name': blob_name,
+       u'size': u'{:d}'.format(len(data)),
    }
    fake_response2._content = json.dumps(payload).encode(u'utf-8')
 
diff --git a/google/resumable_media/requests/upload.py b/google/resumable_media/requests/upload.py
index 235c6c5e..54bca79e 100644
--- a/google/resumable_media/requests/upload.py
+++ b/google/resumable_media/requests/upload.py
@@ -121,9 +121,21 @@ class ResumableUpload(_helpers.RequestsMixin, _upload.ResumableUpload):
             :data:`.UPLOAD_CHUNK_SIZE`.
     """
 
-    def initiate(self, transport, stream, metadata, content_type):
+    def initiate(self, transport, stream, metadata, content_type,
+                 total_bytes=None, stream_final=True):
         """Initiate a resumable upload.
 
+        By default, this method assumes your ``stream`` is in a "final"
+        state ready to transmit. However, ``stream_final=False`` can be used
+        to indicate that the size of the resource is not known. This can happen
+        if bytes are being dynamically fed into ``stream``, e.g. if the stream
+        is attached to application logs.
+
+        If ``stream_final=False`` is used, :attr:`chunk_size` bytes will be
+        read from the stream every time :meth:`transmit_next_chunk` is called.
+        If one of those reads produces strictly fewer bites than the chunk
+        size, the upload will be concluded.
+
         Args:
             transport (~requests.Session): A ``requests`` object which can
                 make authenticated requests.
@@ -134,12 +146,19 @@ def initiate(self, transport, stream, metadata, content_type):
                 ACL list.
             content_type (str): The content type of the resource, e.g. a JPEG
                 image has content type ``image/jpeg``.
+            total_bytes (Optional[int]): The total number of bytes to be
+                uploaded. If specified, the upload size **will not** be
+                determined from the stream (even if ``stream_final=True``).
+            stream_final (Optional[bool]): Indicates if the ``stream`` is
+                "final" (i.e. no more bytes will be added to it). In this case
+                we determine the upload size from the size of the stream. If
+                ``total_bytes`` is passed, this argument will be ignored.
 
         Returns:
             ~requests.Response: The HTTP response returned by ``transport``.
         """
         method, url, payload, headers = self._prepare_initiate_request(
-            stream, metadata, content_type)
+            stream, metadata, content_type, stream_final=stream_final)
         result = _helpers.http_request(
             transport, method, url, data=payload, headers=headers)
         self._process_initiate_response(result)
@@ -148,6 +167,11 @@ def initiate(self, transport, stream, metadata, content_type):
     def transmit_next_chunk(self, transport):
         """Transmit the next chunk of the resource to be uploaded.
 
+        If the current upload was initiated with ``stream_final=False``,
+        this method will dynamically determine if the upload has completed.
+        The upload will be considered complete if the stream produces
+        fewer than :attr:`chunk_size` bytes when a chunk is read from it.
+
         In the case of failure, an exception is thrown that preserves the
         failed response:
 
diff --git a/tests/unit/test__upload.py b/tests/unit/test__upload.py
index 970b226e..f7d2a18d 100644
--- a/tests/unit/test__upload.py
+++ b/tests/unit/test__upload.py
@@ -110,6 +110,12 @@ def test__get_headers(self):
 
         exc_info.match(u'virtual')
 
+    def test__get_body(self):
+        with pytest.raises(NotImplementedError) as exc_info:
+            _upload.UploadBase._get_body(None)
+
+        exc_info.match(u'virtual')
+
 
 class TestSimpleUpload(object):
 
@@ -316,7 +322,8 @@ def test_total_bytes_property(self):
         upload._total_bytes = 8192
         assert upload.total_bytes == 8192
 
-    def _prepare_initiate_request_helper(self, upload_headers=None):
+    def _prepare_initiate_request_helper(self, upload_headers=None,
+                                         **method_kwargs):
         data = b'some really big big data.'
         stream = io.BytesIO(data)
         metadata = {u'name': u'big-data-file.txt'}
@@ -330,12 +337,15 @@ def _prepare_initiate_request_helper(self, upload_headers=None):
         assert upload._total_bytes is None
         # Call the method and check the output.
         method, url, payload, headers = upload._prepare_initiate_request(
-            stream, metadata, BASIC_CONTENT)
+            stream, metadata, BASIC_CONTENT, **method_kwargs)
         assert payload == b'{"name": "big-data-file.txt"}'
         # Make sure the ``upload``-s state was updated.
         assert upload._stream == stream
         assert upload._content_type == BASIC_CONTENT
-        assert upload._total_bytes == len(data)
+        if method_kwargs == {u'stream_final': False}:
+            assert upload._total_bytes is None
+        else:
+            assert upload._total_bytes == len(data)
         # Make sure headers are untouched.
         assert headers is not upload._headers
         assert upload._headers == orig_headers
@@ -368,6 +378,27 @@ def test__prepare_initiate_request_with_headers(self):
         }
         assert new_headers == expected_headers
 
+    def test__prepare_initiate_request_known_size(self):
+        total_bytes = 25
+        data, headers = self._prepare_initiate_request_helper(
+            total_bytes=total_bytes)
+        assert len(data) == total_bytes
+        expected_headers = {
+            u'content-type': u'application/json; charset=UTF-8',
+            u'x-upload-content-length': u'{:d}'.format(total_bytes),
+            u'x-upload-content-type': BASIC_CONTENT,
+        }
+        assert headers == expected_headers
+
+    def test__prepare_initiate_request_unknown_size(self):
+        _, headers = self._prepare_initiate_request_helper(
+            stream_final=False)
+        expected_headers = {
+            u'content-type': u'application/json; charset=UTF-8',
+            u'x-upload-content-type': BASIC_CONTENT,
+        }
+        assert headers == expected_headers
+
     def test__prepare_initiate_request_already_initiated(self):
         upload = _upload.ResumableUpload(RESUMABLE_URL, ONE_MB)
         # Fake that the upload has been started.
@@ -425,6 +456,7 @@ def test_initiate(self):
 
     def test__prepare_request_already_finished(self):
         upload = _upload.ResumableUpload(RESUMABLE_URL, ONE_MB)
+        assert not upload.invalid
         upload._finished = True
         with pytest.raises(ValueError) as exc_info:
             upload._prepare_request()
@@ -443,7 +475,8 @@ def test__prepare_request_invalid(self):
 
     def test__prepare_request_not_initiated(self):
         upload = _upload.ResumableUpload(RESUMABLE_URL, ONE_MB)
-        assert not upload._finished
+        assert not upload.finished
+        assert not upload.invalid
         assert upload._resumable_url is None
         with pytest.raises(ValueError) as exc_info:
             upload._prepare_request()
@@ -536,15 +569,18 @@ def test__process_response_success(self):
         upload = _upload.ResumableUpload(RESUMABLE_URL, ONE_MB)
         _fix_up_virtual(upload)
 
-        upload._total_bytes = mock.sentinel.total_bytes
+        total_bytes = 158
+        response_body = u'{{"size": "{:d}"}}'.format(total_bytes)
         # Check status before.
         assert upload._bytes_uploaded == 0
         assert not upload._finished
-        response = _make_response()
+        response = mock.Mock(
+            content=response_body, status_code=http_client.OK,
+            spec=[u'content', u'status_code'])
         ret_val = upload._process_response(response)
         assert ret_val is None
         # Check status after.
-        assert upload._bytes_uploaded is mock.sentinel.total_bytes
+        assert upload._bytes_uploaded == total_bytes
         assert upload._finished
 
     def test__process_response_partial_no_range(self):
@@ -806,26 +842,75 @@ def test_get_total_bytes():
 
 class Test_get_next_chunk(object):
 
-    def test_exhausted(self):
+    def test_exhausted_known_size(self):
         data = b'the end'
         stream = io.BytesIO(data)
         stream.seek(len(data))
-        with pytest.raises(ValueError):
-            _upload.get_next_chunk(stream, 1)
+        with pytest.raises(ValueError) as exc_info:
+            _upload.get_next_chunk(stream, 1, len(data))
+
+        exc_info.match(
+            u'Stream is already exhausted. There is no content remaining.')
+
+    def test_read_past_known_size(self):
+        data = b'more content than we expected'
+        stream = io.BytesIO(data)
+        chunk_size = len(data)
+        total_bytes = chunk_size - 3
+
+        with pytest.raises(ValueError) as exc_info:
+            _upload.get_next_chunk(stream, chunk_size, total_bytes)
+
+        exc_info.match(u'bytes have been read from the stream')
+        exc_info.match(u'exceeds the expected total')
 
-    def test_success(self):
-        stream = io.BytesIO(b'0123456789')
+    def test_success_known_size(self):
+        data = b'0123456789'
+        stream = io.BytesIO(data)
+        total_bytes = len(data)
         chunk_size = 3
         # Splits into 4 chunks: 012, 345, 678, 9
-        result0 = _upload.get_next_chunk(stream, chunk_size)
-        result1 = _upload.get_next_chunk(stream, chunk_size)
-        result2 = _upload.get_next_chunk(stream, chunk_size)
-        result3 = _upload.get_next_chunk(stream, chunk_size)
-        assert result0 == (0, 2, b'012')
-        assert result1 == (3, 5, b'345')
-        assert result2 == (6, 8, b'678')
-        assert result3 == (9, 9, b'9')
-        assert stream.tell() == 10
+        result0 = _upload.get_next_chunk(stream, chunk_size, total_bytes)
+        result1 = _upload.get_next_chunk(stream, chunk_size, total_bytes)
+        result2 = _upload.get_next_chunk(stream, chunk_size, total_bytes)
+        result3 = _upload.get_next_chunk(stream, chunk_size, total_bytes)
+        assert result0 == (0, 2, b'012', u'bytes 0-2/10')
+        assert result1 == (3, 5, b'345', u'bytes 3-5/10')
+        assert result2 == (6, 8, b'678', u'bytes 6-8/10')
+        assert result3 == (9, 9, b'9', u'bytes 9-9/10')
+        assert stream.tell() == total_bytes
+
+    def test_success_unknown_size(self):
+        data = b'abcdefghij'
+        stream = io.BytesIO(data)
+        chunk_size = 6
+        # Splits into 4 chunks: abcdef, ghij
+        result0 = _upload.get_next_chunk(stream, chunk_size, None)
+        result1 = _upload.get_next_chunk(stream, chunk_size, None)
+        assert result0 == (0, chunk_size - 1, b'abcdef', u'bytes 0-5/*')
+        assert result1 == (chunk_size, len(data) - 1, b'ghij', u'bytes 6-9/10')
+        assert stream.tell() == len(data)
+
+        # Do the same when the chunk size evenly divides len(data)
+        stream.seek(0)
+        chunk_size = len(data)
+        # Splits into 2 chunks: `data` and empty string
+        result0 = _upload.get_next_chunk(stream, chunk_size, None)
+        result1 = _upload.get_next_chunk(stream, chunk_size, None)
+        assert result0 == (0, len(data) - 1, data, u'bytes 0-9/*')
+        assert result1 == (len(data), len(data) - 1, b'', u'bytes */10')
+        assert stream.tell() == len(data)
+
+
+class Test_get_content_range(object):
+
+    def test_known_size(self):
+        result = _upload.get_content_range(5, 10, 40)
+        assert result == u'bytes 5-10/40'
+
+    def test_unknown_size(self):
+        result = _upload.get_content_range(1000, 10000, None)
+        assert result == u'bytes 1000-10000/*'
 
 
 def _make_response(status_code=http_client.OK, headers=None):
@@ -843,6 +928,11 @@ def _get_headers(response):
     return response.headers
 
 
+def _get_body(response):
+    return response.content
+
+
 def _fix_up_virtual(upload):
     upload._get_status_code = _get_status_code
     upload._get_headers = _get_headers
+    upload._get_body = _get_body