X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=api%2Fapi.go;h=c4f069faadcfbf840eafab03785f443c2ee65b86;hb=a4112fac7b86fe09650d2bb57969fe46404edd7d;hp=3089f24759aef932e1fbf7cf70d72a1829db6a4c;hpb=c0da1f2999a6b08d003c0fed1a23e1ca60dd1571;p=govpp.git diff --git a/api/api.go b/api/api.go index 3089f24..c4f069f 100644 --- a/api/api.go +++ b/api/api.go @@ -36,21 +36,16 @@ type Connection interface { // Stream provides low-level access for sending and receiving messages. // Users should handle correct type and ordering of messages. // +// It is not safe to call these methods on the same stream in different +// goroutines. +// // NOTE: This API is EXPERIMENTAL. type Stream interface { // SendMsg sends a message to the client. // It blocks until message is sent to the transport. - // - // It is safe to have a goroutine calling SendMsg and another goroutine - // calling RecvMsg on the same stream at the same time, but it is not safe - // to call SendMsg on the same stream in different goroutines. SendMsg(Message) error // RecvMsg blocks until a message is received or error occurs. - // - // It is safe to have a goroutine calling SendMsg and another goroutine - // calling RecvMsg on the same stream at the same time, but it is not safe - // to call SendMsg on the same stream in different goroutines. RecvMsg() (Message, error) // Close closes the stream. Calling SendMsg and RecvMsg will return error