runtimelog

Documentation

Index

• type HardCancelReader
  • func NewHardCancelReader(ctx context.Context, reader io.Reader) *HardCancelReader
  • func (r *HardCancelReader) LastReadTime() time.Time
  • func (r *HardCancelReader) Read(b []byte) (int, error)

Types

type HardCancelReader

type HardCancelReader struct {
	Now func() time.Time
	// contains filtered or unexported fields
}

A reader that will stop returning data after its context has been canceled.

If any data is read from the underlying stream after the cancel happens, throw the data out.

func NewHardCancelReader

func NewHardCancelReader(ctx context.Context, reader io.Reader) *HardCancelReader

func (*HardCancelReader) LastReadTime

func (r *HardCancelReader) LastReadTime() time.Time

func (*HardCancelReader) Read

func (r *HardCancelReader) Read(b []byte) (int, error)