testchannel

Documentation

Index

• func DrainChannel[V any](ch <-chan V) error

Functions

func DrainChannel

func DrainChannel[V any](ch <-chan V) error

DrainChannel attempts to receive from the given channel, blocking, until it is empty. It returns an error if the channel is not closed by the time it's empty. TODO_CONSIDERATION: this function could easily take a timeout parameter and add a case which returns an error if the timeout is exceeded. This would prevent the case where the channel never stops receiving from looping indefinitely.