iochan

Documentation

Overview

allows for streaming an io.Reader to a channel and an io.Writer from a channel

Index

• func ReaderChan(ctx context.Context, r io.Reader, chunkSize int64, callback func()) chan wshrpc.RespOrErrorUnion[iochantypes.Packet]
• func WriterChan(ctx context.Context, w io.Writer, ...)

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