Update imports due to rename of repo nats to go-nats

nats-io · Nov 21, 2016 · 4a5993b · 4a5993b
1 parent 46225c6
commit 4a5993b
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 10 deletions.
diff --git a/examples/stan-bench.go b/examples/stan-bench.go
@@ -11,10 +11,9 @@ import (
 	"sync"
 	"time"
 
+	"github.com/nats-io/go-nats"
 	"github.com/nats-io/go-nats-streaming"
-	"github.com/nats-io/nats"
-	"github.com/nats-io/nats/bench"
-
+	"github.com/nats-io/go-nats/bench"
 )
 
 // Some sane defaults

diff --git a/stan.go b/stan.go
@@ -10,8 +10,8 @@ import (
 	"sync"
 	"time"
 
+	"github.com/nats-io/go-nats"
 	"github.com/nats-io/go-nats-streaming/pb"
-	"github.com/nats-io/nats"
 	"github.com/nats-io/nuid"
 )
 

diff --git a/stan_test.go b/stan_test.go
@@ -18,13 +18,12 @@ import (
 	"testing"
 	"time"
 
+	natsd "github.com/nats-io/gnatsd/test"
+	"github.com/nats-io/go-nats"
 	"github.com/nats-io/go-nats-streaming/pb"
-	"github.com/nats-io/nats"
+	natstest "github.com/nats-io/go-nats/test"
 	"github.com/nats-io/nats-streaming-server/server"
 	"github.com/nats-io/nats-streaming-server/test"
-	natstest "github.com/nats-io/nats/test"
-
-	natsd "github.com/nats-io/gnatsd/test"
 )
 
 func RunServer(ID string) *server.StanServer {
@@ -1245,7 +1244,7 @@ func TestDurableSubscriber(t *testing.T) {
 		if nr := atomic.AddInt32(&received, 1); nr == 10 {
 			// Reduce risk of test failure by allowing server to
 			// process acks before processing Close() requesting
-			time.Sleep(500 * time.Millisecond)
+			time.Sleep(time.Second)
 			sc.Close()
 			ch <- true
 		} else {

diff --git a/sub.go b/sub.go
@@ -8,8 +8,8 @@ import (
 	"sync"
 	"time"
 
+	"github.com/nats-io/go-nats"
 	"github.com/nats-io/go-nats-streaming/pb"
-	"github.com/nats-io/nats"
 )
 
 const (