mirror of
https://github.com/eosswedenorg/thalos
synced 2026-06-16 04:24:56 +02:00
transport/reader.go: Add Close() method
This commit is contained in:
parent
65173425a6
commit
70bc689736
1 changed files with 4 additions and 0 deletions
|
|
@ -10,4 +10,8 @@ type Reader interface {
|
|||
//
|
||||
// This function should be designed to handle concurrent calls. eg. thread safe.
|
||||
Read(channel Channel) ([]byte, error)
|
||||
|
||||
// Close closes the reader
|
||||
// Any blocked Read operations will be unblocked.
|
||||
Close() error
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue