Struct cyfs_bdt::ndn::channel::channel::Channel

pub struct Channel(_);

Implementations

impl Channel

pub fn new( weak_stack: Weak<StackImpl>, tunnel: TunnelGuard, command_tunnel: DatagramTunnelGuard ) -> Self

pub fn ref_count(&self) -> usize

pub fn to_weak(&self) -> WeakChannel

pub fn tunnel(&self) -> &TunnelGuard

pub fn config(&self) -> &Config

pub fn upload( &self, chunk: ChunkId, session_id: TempSeq, piece_type: ChunkCodecDesc, encoder: Box<dyn ChunkEncoder> ) -> BuckyResult<UploadSession>

pub fn download( &self, chunk: ChunkId, source: DownloadSource<DeviceId>, cache: ChunkStreamCache, referer: Option<String>, group_path: Option<String> ) -> BuckyResult<DownloadSession>

pub fn interest(&self, interest: Interest)

pub fn resp_interest(&self, resp: RespInterest)

Examples found in repository

examples/single_source.rs (line 87)

            async fn on_newly_interest(
                &self, 
                _stack: &Stack, 
                interest: &Interest, 
                from: &Channel
            ) -> BuckyResult<()> {
                let resp = RespInterest {
                    session_id: interest.session_id.clone(), 
                    chunk: interest.chunk.clone(), 
                    err: BuckyErrorCode::NotFound, 
                    redirect: None,
                    redirect_referer: None,
                    to: None,
                };

                from.resp_interest(resp);
                Ok(())
            }

pub fn stack(&self) -> Stack

pub fn state(&self) -> ChannelState

pub fn calc_speed(&self, when: Timestamp) -> (u32, u32)

pub fn download_session_count(&self) -> u32

pub fn download_cur_speed(&self) -> u32

pub fn download_history_speed(&self) -> u32

pub fn upload_session_count(&self) -> u32

pub fn upload_cur_speed(&self) -> u32

pub fn upload_history_speed(&self) -> u32

impl Channel

pub fn on_raw_data(&self, data: &[u8], tunnel: DynamicTunnel) -> BuckyResult<()>

pub fn on_time_escape(&self, now: Timestamp)

Trait Implementations

impl Clone for Channel

fn clone(&self) -> Channel

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Display for Channel

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

Formats the value using the given formatter.