diff --git a/tcp-connection.go b/tcp-connection.go index b0e5525..dc7d962 100644 --- a/tcp-connection.go +++ b/tcp-connection.go @@ -162,11 +162,12 @@ func (c *Connection) Listen() (*GenericListener, error) { } const ( - MaxCallDuration = 1500 * time.Millisecond + MaxCallDuration = 2500 * time.Millisecond ) func (l *GenericListener) HandleConnection(conn net.Conn) { ch := make(chan FrameWithPayload, 1) + conn.SetReadDeadline(time.Now().Add(MaxCallDuration)) go WaitForFrame(conn, ch) select { case frame := <-ch: