From 6fed9dd0dd62718f78eca11e30a71c2712636fbd Mon Sep 17 00:00:00 2001 From: Mikhail Osipov Date: Wed, 16 Dec 2020 15:27:48 +0300 Subject: hook and socket args check fix, tests --- pkg/server/socket/loop.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'pkg/server/socket/loop.go') diff --git a/pkg/server/socket/loop.go b/pkg/server/socket/loop.go index a06448a..c442140 100644 --- a/pkg/server/socket/loop.go +++ b/pkg/server/socket/loop.go @@ -30,7 +30,7 @@ func (c *loopConn) Close() error { return nil } -func (s *loopSocket) Open(env.Env) (Conn, error) { +func (s *loopSocket) New(env.Env) (Conn, error) { return &loopConn{make(chan queue.Q), make(chan error)}, nil } @@ -41,6 +41,6 @@ func (s *loopSocket) String() string { func (s *loopSocket) Close() { } -func newLoopSocket() (S, error) { - return &loopSocket{}, nil +func init() { + register("loop", loopSocket{}) } -- cgit v1.2.3-70-g09d2