Struct DownloadResult 

pub struct DownloadResult<E, PullError, PushError>
where
    E: Executor + Send + Sync,
    PullError: Send + Unpin + 'static,
    PushError: Send + Unpin + 'static,
{
    pub event_chain: MAsyncRx<FlavorWrap<List<Event<PullError, PushError>>, RegistryDummy, RegistryMulti<()>>>,
    /* private fields */
}

Fields

event_chain: MAsyncRx<FlavorWrap<List<Event<PullError, PushError>>, RegistryDummy, RegistryMulti<()>>>

Implementations

impl<E, PullError, PushError> DownloadResult<E, PullError, PushError>

where E: Executor + Send + Sync, PullError: Send + Unpin + 'static, PushError: Send + Unpin + 'static,

pub fn new( event_chain: MAsyncRx<FlavorWrap<List<Event<PullError, PushError>>, RegistryDummy, RegistryMulti<()>>>, handle: JoinHandle<()>, abort_handles: Option<&[AbortHandle]>, task_queue: Option<(Weak<E>, TaskQueue<<E as Executor>::Handle>)>, ) -> DownloadResult<E, PullError, PushError>

pub async fn join(&self) -> Result<(), Arc<JoinError>>

Errors

当写入线程意外退出时返回 Arc<JoinError>

pub fn abort(&self)

pub fn set_threads(&self, threads: usize, min_chunk_size: u64)

pub fn is_aborted(&self) -> bool

Trait Implementations

impl<E, PullError, PushError> Clone for DownloadResult<E, PullError, PushError>

where E: Executor + Send + Sync, PullError: Send + Unpin + 'static, PushError: Send + Unpin + 'static,

fn clone(&self) -> DownloadResult<E, PullError, PushError>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E, PullError, PushError> Debug for DownloadResult<E, PullError, PushError>

where E: Debug + Executor + Send + Sync, PullError: Debug + Send + Unpin + 'static, PushError: Debug + Send + Unpin + 'static, <E as Executor>::Handle: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<E, PullError, PushError> Drop for DownloadResult<E, PullError, PushError>

where E: Executor + Send + Sync, PullError: Send + Unpin + 'static, PushError: Send + Unpin + 'static,

fn drop(&mut self)

Executes the destructor for this type.