kd.types.StreamWriter API

Stream writer.

Note: This class supports parametrization like StreamWriter[T].

Note: It is strongly advised that all streams be explicitly closed.

StreamWriter.close(exception=None)

Closes the stream.

StreamWriter.orphaned()

Returns true if the stream no longer has any readers.

StreamWriter.write(item, /)

Write an item to the stream.