diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-05-05 20:10:08 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-05-05 20:10:08 +0300 |
| commit | b089b35f35a14e85d89df69254cc61495d59d3dd (patch) | |
| tree | da07e5b015e02f7fa05cf0be181697670af787ed /pkg/server/socket/loop.go | |
| parent | f44d6e1a111154b70aaeac9ffe38beaee2cc5dd7 (diff) | |
add http connect proxy server
Diffstat (limited to 'pkg/server/socket/loop.go')
| -rw-r--r-- | pkg/server/socket/loop.go | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/pkg/server/socket/loop.go b/pkg/server/socket/loop.go index 88e9491..a06448a 100644 --- a/pkg/server/socket/loop.go +++ b/pkg/server/socket/loop.go @@ -7,31 +7,31 @@ import ( type loopSocket struct{} -type loopChannel struct { +type loopConn struct { c chan queue.Q q chan error } -func (c *loopChannel) Send(wq queue.Q) error { +func (c *loopConn) Send(wq queue.Q) error { c.c <- wq return <-c.q } -func (c *loopChannel) Recv(rq queue.Q) error { +func (c *loopConn) Recv(rq queue.Q) error { defer close(c.q) return queue.Copy(rq, <-c.c) } -func (c *loopChannel) String() string { +func (c *loopConn) String() string { return "loop" } -func (c *loopChannel) Close() error { +func (c *loopConn) Close() error { return nil } -func (s *loopSocket) Open(env.Env) (Channel, error) { - return &loopChannel{make(chan queue.Q), make(chan error)}, nil +func (s *loopSocket) Open(env.Env) (Conn, error) { + return &loopConn{make(chan queue.Q), make(chan error)}, nil } func (s *loopSocket) String() string { |
