gossamer - v7.0.0

gossamer/readable_stream

Types

ReadableStream

</> 
pub type ReadableStream(a)

StreamPipeOption

</> 
pub type StreamPipeOption {
  PreventAbort
  PreventCancel
  PreventClose
  Signal(abort_signal.AbortSignal)
}

Constructors

UnderlyingSource

</> 
pub type UnderlyingSource(a) {
  Start(fn(default_controller.DefaultController(a)) -> Nil)
  Pull(
    fn(default_controller.DefaultController(a)) -> promise.Promise(
      Nil,
    ),
  )
  Cancel(fn(dynamic.Dynamic) -> promise.Promise(Nil))
}

Constructors

Values

async_iterator

</> 
pub fn async_iterator(
  of stream: ReadableStream(a),
) -> async_iterator.AsyncIterator(a, Nil, Nil)

cancel

</> 
pub fn cancel(
  stream: ReadableStream(a),
  reason reason: r,
) -> promise.Promise(Result(Nil, String))

from_async_iterator

</> 
pub fn from_async_iterator(
  iterator: async_iterator.AsyncIterator(a, r, n),
) -> ReadableStream(a)

Creates a ReadableStream from an AsyncIterator.

Note: Not available on Bun. See https://github.com/oven-sh/bun/issues/3700

from_iterator

</> 
pub fn from_iterator(
  iterator: iterator.Iterator(a, r, n),
) -> ReadableStream(a)

Creates a ReadableStream from an Iterator.

Note: Not available on Bun. See https://github.com/oven-sh/bun/issues/3700

from_pull

</> 
pub fn from_pull(
  pull: fn(default_controller.DefaultController(a)) -> promise.Promise(
    Nil,
  ),
) -> ReadableStream(a)

from_start

</> 
pub fn from_start(
  start: fn(default_controller.DefaultController(a)) -> Nil,
) -> ReadableStream(a)

get_byob_reader

</> 
pub fn get_byob_reader(
  stream: ReadableStream(a),
) -> Result(byob_reader.ByobReader(a), String)

get_reader

</> 
pub fn get_reader(
  stream: ReadableStream(a),
) -> Result(reader.Reader(a), String)

is_locked

</> 
pub fn is_locked(stream: ReadableStream(a)) -> Bool

new

</> 
pub fn new(
  source: List(UnderlyingSource(a)),
) -> ReadableStream(a)

pipe_through

</> 
pub fn pipe_through(
  stream: ReadableStream(a),
  transform: #(
    ReadableStream(b),
    writable_stream.WritableStream(a),
  ),
  with options: List(StreamPipeOption),
) -> Result(ReadableStream(b), String)

pipe_to

</> 
pub fn pipe_to(
  stream: ReadableStream(a),
  destination: writable_stream.WritableStream(a),
  with options: List(StreamPipeOption),
) -> promise.Promise(Result(Nil, String))

tee

</> 
pub fn tee(
  stream: ReadableStream(a),
) -> Result(#(ReadableStream(a), ReadableStream(a)), String)
✨ Search Document