Package akka.io
Class TcpConnection.PendingWriteFile
- java.lang.Object
-
- akka.io.TcpConnection.PendingWrite
-
- akka.io.TcpConnection.PendingWriteFile
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- TcpConnection
public class TcpConnection.PendingWriteFile extends TcpConnection.PendingWrite implements java.lang.Runnable
-
-
Constructor Summary
Constructors Constructor Description PendingWriteFile(ActorRef commander, java.nio.channels.FileChannel fileChannel, long offset, long remaining, Tcp.Event ack, Tcp.WriteCommand tail)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ActorRef
commander()
TcpConnection.PendingWrite
doWrite(TcpConnection.ConnectionInfo info)
void
release()
void
run()
-
-
-
Constructor Detail
-
PendingWriteFile
public PendingWriteFile(ActorRef commander, java.nio.channels.FileChannel fileChannel, long offset, long remaining, Tcp.Event ack, Tcp.WriteCommand tail)
-
-
Method Detail
-
commander
public ActorRef commander()
- Specified by:
commander
in classTcpConnection.PendingWrite
-
doWrite
public TcpConnection.PendingWrite doWrite(TcpConnection.ConnectionInfo info)
- Specified by:
doWrite
in classTcpConnection.PendingWrite
-
release
public void release()
- Specified by:
release
in classTcpConnection.PendingWrite
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
-