Package org.filestack.internal

Class UploadTransferFunc

java.lang.Object

org.filestack.internal.UploadTransferFunc

All Implemented Interfaces:

io.reactivex.FlowableOnSubscribe<org.filestack.internal.Prog>

public class UploadTransferFunc
extends Object
implements io.reactivex.FlowableOnSubscribe<org.filestack.internal.Prog>

Function to be passed to Flowable.create(FlowableOnSubscribe, BackpressureStrategy). This class handles uploading of parts/chunks and makes calls to both S3 and Filestack endpoints. An upload should be divided between multiple instances. Different instances are not assigned to section of the file, instead we synchronize reads.

Method Summary

Modifier and Type	Method	Description
void	subscribe(io.reactivex.FlowableEmitter<org.filestack.internal.Prog> e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

subscribe

public void subscribe(io.reactivex.FlowableEmitter<org.filestack.internal.Prog> e)
               throws Exception

Specified by:

subscribe in interface io.reactivex.FlowableOnSubscribe<org.filestack.internal.Prog>

Throws:

Exception