Struct cyfs_bdt::utils::SampleDownloadContext

pub struct SampleDownloadContext(_);

Implementations

impl SampleDownloadContext

pub fn ptr_eq(&self, other: &Self) -> bool

pub fn new(referer: String) -> Self

pub fn desc_streams(referer: String, remotes: Vec<DeviceDesc>) -> Self

Examples found in repository

examples/upload_download.rs (line 96)

            async fn on_newly_interest(
                &self, 
                stack: &Stack, 
                interest: &Interest, 
                from: &Channel
            ) -> BuckyResult<()> {
                let (_, reader) = download_chunk(
                    stack,
                    interest.chunk.clone(), 
                    None, 
                    SampleDownloadContext::desc_streams("".to_owned(), vec![self.src_dev.desc().clone()]),
                ).await.unwrap();
                {
                    let store = self.store.clone();
                    let chunk = interest.chunk.clone();
                    task::spawn(async move {
                        store.write_chunk(&chunk, reader).await.unwrap();
                    });
                }
                self.default.on_newly_interest(stack, interest, from).await
            }

pub async fn id_streams( stack: &Stack, referer: String, remotes: &[DeviceId] ) -> BuckyResult<Self>

pub fn add_source(&self, source: DownloadSource<DeviceDesc>)

Trait Implementations

impl Clone for SampleDownloadContext

fn clone(&self) -> SampleDownloadContext

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for SampleDownloadContext

fn default() -> Self

Returns the “default value” for a type.

impl DownloadContext for SampleDownloadContext

fn clone_as_context(&self) -> Box<dyn DownloadContext>

fn referer(&self) -> &str

fn update_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Timestamp> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn sources_of<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 DownloadSourceFilter, limit: usize ) -> Pin<Box<dyn Future<Output = (LinkedList<DownloadSource<DeviceDesc>>, Timestamp)> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn is_mergable(&self) -> bool

fn on_new_session( &self, _task: &dyn LeafDownloadTask, _session: &DownloadSession, _update_at: Timestamp )

fn on_drain(&self, _task: &dyn LeafDownloadTask, _update_at: Timestamp)