Documentation
¶
Overview ¶
allows for streaming an io.Reader to a channel and an io.Writer from a channel
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ReaderChan ¶
func ReaderChan(ctx context.Context, r io.Reader, chunkSize int64, callback func()) chan wshrpc.RespOrErrorUnion[iochantypes.Packet]
ReaderChan reads from an io.Reader and sends the data to a channel
func WriterChan ¶
func WriterChan(ctx context.Context, w io.Writer, ch <-chan wshrpc.RespOrErrorUnion[iochantypes.Packet], callback func(), cancel context.CancelCauseFunc)
WriterChan reads from a channel and writes the data to an io.Writer
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.