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[[]byte]
• func WriterChan(ctx context.Context, w io.Writer, ch <-chan wshrpc.RespOrErrorUnion[[]byte], ...)

Functions

func ReaderChan

func ReaderChan(ctx context.Context, r io.Reader, chunkSize int64, callback func()) chan wshrpc.RespOrErrorUnion[[]byte]

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[[]byte], callback func(), errCallback func(error))

WriterChan reads from a channel and writes the data to an io.Writer