internal

Documentation

Index

• func Copy(ctx context.Context, dst io.Writer, src io.Reader) error
• func Copyd(done <-chan struct{}, dst io.Writer, src io.Reader) error
• func IsCaredNetError(err error) bool
• func OnRead(done <-chan struct{}, src io.Reader, onRead writerFunc) error

Functions

func Copy

func Copy(ctx context.Context, dst io.Writer, src io.Reader) error

slightly modified function signature: - context has been added in order to propagate cancelation - I do not return the number of bytes written, has it is not useful in my use case

func Copyd

func Copyd(done <-chan struct{}, dst io.Writer, src io.Reader) error

func IsCaredNetError

func IsCaredNetError(err error) bool

IsCaredNetError detects an error if it should be cared by socketlib

func OnRead

func OnRead(done <-chan struct{}, src io.Reader, onRead writerFunc) error