eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-08-23 19:48:12 +02:00
Code Releases Activity

transport/reader.go: document concurrency requirement of Read()

Browse source
This commit is contained in:
Henrik Hautakoski 2023-03-29 11:38:54 +02:00
parent 531a2d3d17
commit bbda49ab90
1 changed files with 2 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
transport/reader.go
View file

@ -7,5 +7,7 @@ package transport
type Reader interface { type Reader interface {
// Read a message from a channel. // Read a message from a channel.
// Read may block until a message is ready or an error occured. // Read may block until a message is ready or an error occured.
//
// This function should be designed to handle concurrent calls. eg. thread safe.
Read(channel Channel) ([]byte, error) Read(channel Channel) ([]byte, error)
} }