rio

Documentation

Index

• func CopyBuffer(dst io.Writer, src io.Reader, wch chan int64) (err error)
• func CopyConn(c1 io.ReadWriteCloser, c2 io.ReadWriteCloser)
• func CopyConnWithOnClose(c1 io.ReadWriteCloser, c2 io.ReadWriteCloser, metrics bool, onClose func()) chan int64

Functions

func CopyBuffer

func CopyBuffer(dst io.Writer, src io.Reader, wch chan int64) (err error)

borrowed from the official go io package with some changes to support throughput metrics

func CopyConn

func CopyConn(c1 io.ReadWriteCloser, c2 io.ReadWriteCloser)

CopyConn copy packets from c1 to c2 and viceversa

func CopyConnWithOnClose

func CopyConnWithOnClose(
	c1 io.ReadWriteCloser,
	c2 io.ReadWriteCloser,
	metrics bool,
	onClose func()) chan int64

CopyConnWithOnClose copy packets from c1 to c2 and viceversa. Calls the onClose function when the connection is interrupted