gopkg/puddle
2
0
Fork 0
Code Activity

Replace interface{} with any

Browse Source
This commit is contained in:
Jack Christensen
2022-09-03 13:10:10 -05:00
parent fdc2381cbe
commit 30b2cb627e
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pool_test.go
+4 -4
View File
@@ -865,13 +865,13 @@ func TestPoolAcquireReturnsErrorWhenPoolIsClosed(t *testing.T) {
func TestSignalIsSentWhenResourceFailedToCreate(t *testing.T) { func TestSignalIsSentWhenResourceFailedToCreate(t *testing.T) {
var c Counter var c Counter
constructor := func(context.Context) (a interface{}, err error) { constructor := func(context.Context) (a any, err error) {
if c.Next() == 2 { if c.Next() == 2 {
return nil, errors.New("outage") return nil, errors.New("outage")
} }
return 1, nil return 1, nil
} }
destructor := func(value interface{}) {} destructor := func(value any) {}
pool, err := puddle.NewPool(&puddle.Config[any]{Constructor: constructor, Destructor: destructor, MaxSize: 10}) pool, err := puddle.NewPool(&puddle.Config[any]{Constructor: constructor, Destructor: destructor, MaxSize: 10})
require.NoError(t, err) require.NoError(t, err)
@@ -1035,10 +1035,10 @@ func ExamplePool() {
startAcceptOnceDummyServer(laddr) startAcceptOnceDummyServer(laddr)
// Pool creation // Pool creation
constructor := func(context.Context) (interface{}, error) { constructor := func(context.Context) (any, error) {
return net.Dial("tcp", laddr) return net.Dial("tcp", laddr)
} }
destructor := func(value interface{}) { destructor := func(value any) {
value.(net.Conn).Close() value.(net.Conn).Close()
} }
maxPoolSize := int32(10) maxPoolSize := int32(10)