diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-12-16 15:27:48 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-12-16 15:27:48 +0300 |
| commit | 6fed9dd0dd62718f78eca11e30a71c2712636fbd (patch) | |
| tree | 8d1f90b96efbe8ea8aea350c283325adc216ef9d /pkg/server/socket/loop.go | |
| parent | 050ea053dd549f0dd01beddfcd74989858391fd7 (diff) | |
hook and socket args check fix, tests
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{}) } |
