Files

24 lines
492 B
Go

package natstesting
import (
. "github.com/onsi/ginkgo/v2"
logging "github.com/hanzo-fi/go-libs/v5/pkg/observe/log"
"github.com/hanzo-fi/go-libs/v5/pkg/testing/deferred"
)
func WithNewNatsServer(logger logging.Logger, fn func(p *deferred.Deferred[*NatsServer])) bool {
return Context("With new nats server", func() {
ret := deferred.New[*NatsServer]()
BeforeEach(func() {
ret.Reset()
ret.SetValue(CreateServer(
GinkgoT(),
true,
logger,
))
})
fn(ret)
})
}