gossamer/writable_stream

Types

UnderlyingSink

pub type UnderlyingSink(a) {
  Start(fn(default_controller.DefaultController) -> Nil)
  Write(
    fn(a, default_controller.DefaultController) -> promise.Promise(
      Nil,
    ),
  )
  Close(fn() -> promise.Promise(Nil))
  Abort(fn(dynamic.Dynamic) -> promise.Promise(Nil))
}

Constructors

Start(fn(default_controller.DefaultController) -> Nil)

Write(
  fn(a, default_controller.DefaultController) -> promise.Promise(
    Nil,
  ),
)

```
Close(fn() -> promise.Promise(Nil))
```

Abort(fn(dynamic.Dynamic) -> promise.Promise(Nil))

WritableStream

</>

pub type WritableStream(a)

Values

abort

</>

pub fn abort(
  stream: WritableStream(a),
  reason reason: r,
) -> promise.Promise(Result(Nil, String))

close

</>

pub fn close(
  stream: WritableStream(a),
) -> promise.Promise(Result(Nil, String))

from_write

</>

pub fn from_write(
  write: fn(a, default_controller.DefaultController) -> promise.Promise(
    Nil,
  ),
) -> WritableStream(a)

get_writer

</>

pub fn get_writer(
  stream: WritableStream(a),
) -> Result(writer.Writer(a), String)

is_locked

</>

pub fn is_locked(stream: WritableStream(a)) -> Bool

new

</>

pub fn new(sink: List(UnderlyingSink(a))) -> WritableStream(a)