fix async send timeout bug

funny · Feb 6, 2015 · ff07cdc · ff07cdc
1 parent 59ccbcc
commit ff07cdc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/session.go b/session.go
@@ -243,7 +243,7 @@ func (session *Session) AsyncSend(message Message, timeout time.Duration) AsyncW
 					case session.asyncSendChan <- asyncMessage{c, message}:
 					case <-session.closeChan:
 						c <- SendToClosedError
-					case <-time.After(time.Second * 5):
+					case <-time.After(timeout):
 						session.Close()
 						c <- AsyncSendTimeoutError
 					}
@@ -272,7 +272,7 @@ func (session *Session) asyncSendBuffer(buffer *OutBuffer, timeout time.Duration
 					case session.asyncSendBufferChan <- asyncBuffer{c, buffer}:
 					case <-session.closeChan:
 						c <- SendToClosedError
-					case <-time.After(time.Second * 5):
+					case <-time.After(timeout):
 						session.Close()
 						c <- AsyncSendTimeoutError
 					}