diff options
Diffstat (limited to 'pkg/server/socket/loop.go')
| -rw-r--r-- | pkg/server/socket/loop.go | 6 |
1 files changed, 3 insertions, 3 deletions
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{}) } |
