Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func TimeoutReader ¶
func TimeoutReader(ctx context.Context, r io.Reader, timeout time.Duration, cancel func(uint64)) io.Reader
TimeoutReader creates a new timeoutReader instance and starts a goroutine that monitors the progress of reading from the given reader. If no progress is made for the duration of the given timeout, then the reader executes the given cancel function and terminates the underlying goroutine. This goroutine will also terminate when the given context is canceled or if the n (returned by the given reader) is equal to 0.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.