File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -25,7 +25,7 @@ class FtpClient(val ftpstate: FtpState) extends Matchers {
25
25
private [client] var ctrl : ActorRef = _
26
26
private var portOrPasv : Option [PortOrPasvMode ] = None
27
27
private val portPort = 6004
28
- implicit val timeout : Timeout = 1 second
28
+ implicit val timeout : Timeout = 3 second
29
29
30
30
var replies : List [Reply ] = _
31
31
var connected = false
@@ -301,7 +301,7 @@ class DataConnector(client: FtpClient) extends Actor with ActorLogging {
301
301
log.debug(" Connected to remote address {}" , remote)
302
302
val ref = context.actorOf(DataConnection .props(remote, sender, sendOrReceive))
303
303
sender ! Tcp .Register (ref)
304
- delay(300 milliseconds) // todo How to know when the connection is registered thus the date can be pushed to the server?
304
+ delay(500 milliseconds) // todo How to know when the connection is registered thus the data can be pushed to the server?
305
305
channel.foreach(ref ! ) // send data to the server
306
306
307
307
case Tcp .Bound (remote) =>
You can’t perform that action at this time.
0 commit comments