mirror/opencloud
1
0
Fork 0
mirror of https://github.com/opencloud-eu/opencloud.git synced 2026-05-12 22:39:34 -05:00
Code Issues Packages Projects Releases Wiki Activity

incorporate review feedback

Browse Source
This commit is contained in:
Willy Kloucek
2022-03-07 08:15:50 +01:00
parent 26852f1850
commit 37b56d920e
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
nats/pkg/server/nats/nats.go
+5 -1
View File
@@ -8,6 +8,8 @@ import (
stanServer "github.com/nats-io/nats-streaming-server/server"
)
var NATSListenAndServeLoopTimer = 1 * time.Second
type NATSServer struct {
ctx context.Context
@@ -17,6 +19,7 @@ type NATSServer struct {
server *stanServer.StanServer
}
// NewNATSServer returns a new NATSServer
func NewNATSServer(ctx context.Context, opts ...Option) (*NATSServer, error) {
server := &NATSServer{
@@ -32,6 +35,7 @@ func NewNATSServer(ctx context.Context, opts ...Option) (*NATSServer, error) {
return server, nil
}
// ListenAndServe runs the NATSServer in a blocking way until the server is shutdown or an error occurs
func (n *NATSServer) ListenAndServe() (err error) {
n.server, err = stanServer.RunServerWithOpts(
n.stanOpts,
@@ -56,7 +60,7 @@ func (n *NATSServer) ListenAndServe() (err error) {
if n.ctx.Err() != nil {
return nil
}
time.Sleep(1 * time.Second)
time.Sleep(NATSListenAndServeLoopTimer)
}
}