Struct ReadableStreamCore 

pub struct ReadableStreamCore<T> {
    pub state: StreamState,
    pub queue: VecDeque<T>,
    pub high_water_mark: f64,
    pub locked: bool,
}

ReadableStream の純粋コア実装

Fields

state: StreamState

queue: VecDeque<T>

high_water_mark: f64

locked: bool

Implementations

impl<T> ReadableStreamCore<T>

pub fn new(high_water_mark: f64) -> Self

pub fn from_chunks(chunks: Vec<T>) -> Self

バイト列またはデータ配列から直ちに生成するヘルパー

pub fn desired_size(&self) -> f64

バックプレッシャー計算（desiredSize） キューが満杯なら 0 以下、受け入れ可能なら正の値を返す

pub fn enqueue(&mut self, chunk: T) -> Result<(), StreamError>

チャンクをキューに追加（コントローラの enqueue 処理）

pub fn close(&mut self) -> Result<(), StreamError>

ストリームを正常クローズ（コントローラの close 処理）

pub fn error(&mut self, reason: &str)

ストリームをエラー状態に遷移

pub fn acquire_reader(&mut self) -> Result<(), StreamError>

リーダーによる排他ロック取得（getReader）

pub fn release_reader(&mut self) -> Result<(), StreamError>

リーダーのロック解放（releaseLock）

pub fn read_chunk(&mut self) -> Result<ReadResult<T>, StreamError>

リーダーによるチャンク読み出し（read()）

pub fn cancel(&mut self, _reason: &str)

ストリームのキャンセル（cancel(reason)）

pub fn queue_len(&self) -> usize

キュー内の未読チャンク数

pub fn pipe_to( &mut self, dest: &mut WritableStreamCore<T>, options: PipeOptions, ) -> Result<(), StreamError>

ReadableStreamCore から WritableStreamCore へデータをパイピングする

1. 両ストリームの排他的ロックを確保
2. キューからチャンクを順次取り出し宛先へ書き込み
3. 転送完了後、オプションに応じて宛先のクローズ・両ストリームのロック解除を実施

pub fn pipe_through<O, F>( &mut self, transform: &mut TransformStreamCore<T, O>, transform_fn: F, ) -> Result<(), StreamError>

where F: FnMut(T) -> Vec<O>,

ReadableStreamCore を TransformStreamCore を介して別型の ReadableStreamCore へパイピング

Trait Implementations

impl<T: Clone> Clone for ReadableStreamCore<T>

fn clone(&self) -> ReadableStreamCore<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for ReadableStreamCore<T>

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

Formats the value using the given formatter.