Change module name to go.fd.io/govpp

[govpp.git] / core / stream.go

diff --git a/core/stream.go b/core/stream.go
index 2f639b0..86bb99e 100644 (file)
--- a/core/stream.go
+++ b/core/stream.go
@@ -22,7 +22,7 @@ import (
        "sync"
        "time"
 
-       "git.fd.io/govpp.git/api"
+       "go.fd.io/govpp/api"
 )
 
 type Stream struct {
@@ -56,7 +56,11 @@ func (c *Connection) NewStream(ctx context.Context, options ...api.StreamOption)
                option(s)
        }
 
-       s.channel = c.newChannel(s.requestSize, s.replySize)
+       ch, err := c.newChannel(s.requestSize, s.replySize)
+       if err != nil {
+               return nil, err
+       }
+       s.channel = ch
        s.channel.SetReplyTimeout(s.replyTimeout)
 
        // Channel.watchRequests are not started here intentionally, because