Skip to content

Commit 0f001a7

Browse files
committed
update: server
1 parent 54653a9 commit 0f001a7

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

server.go

+10-3
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,11 @@ import (
88
"github.com/amirhnajafiz/stallion/internal"
99
)
1010

11+
type Server interface {
12+
// Handle method generates a new worker for clients.
13+
Handle(conn net.Conn)
14+
}
15+
1116
// NewServer creates a new broker server on given port.
1217
func NewServer(port string) error {
1318
// creating a new server
@@ -23,8 +28,10 @@ func NewServer(port string) error {
2328

2429
// handling our clients
2530
for {
26-
conn, _ := listener.Accept()
27-
28-
serve.Handle(conn)
31+
if conn, er := listener.Accept(); er == nil {
32+
serve.Handle(conn)
33+
} else {
34+
log.Printf("error in client accept: %v\n", er)
35+
}
2936
}
3037
}

0 commit comments

Comments
 (0)