summaryrefslogtreecommitdiff
path: root/pkg/server/socket/loop.go
diff options
context:
space:
mode:
authorMikhail Osipov <mike.osipov@gmail.com>2020-12-16 15:27:48 +0300
committerMikhail Osipov <mike.osipov@gmail.com>2020-12-16 15:27:48 +0300
commit6fed9dd0dd62718f78eca11e30a71c2712636fbd (patch)
tree8d1f90b96efbe8ea8aea350c283325adc216ef9d /pkg/server/socket/loop.go
parent050ea053dd549f0dd01beddfcd74989858391fd7 (diff)
hook and socket args check fix, tests
Diffstat (limited to 'pkg/server/socket/loop.go')
-rw-r--r--pkg/server/socket/loop.go6
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{})
}