Refactoring and fixes

* refactor creation of new channel
* add missing closing of created streams
* correct documentation regarding thread safety of stream

Signed-off-by: mhalaj1 <matus.halaj@pantheon.tech>
Change-Id: Ic601efff298fcbdecaafab83fa236253af69de21

1 files changed, 3 insertions, 8 deletions

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