Package org.apache.pekko.io

Class Tcp.WritePath

java.lang.Object

org.apache.pekko.io.Tcp.WriteCommand

org.apache.pekko.io.Tcp.SimpleWriteCommand

org.apache.pekko.io.Tcp.WritePath

All Implemented Interfaces:

Serializable, NoSerializationVerificationNeeded, org.apache.pekko.io.SelectionHandler.HasFailureMessage, Tcp.Command, Tcp.Message, scala.Equals, scala.Product

Enclosing class:

Tcp

public static final class Tcp.WritePath
extends Tcp.SimpleWriteCommand
implements scala.Product, Serializable

Write count bytes starting at position from file at filePath to the connection. The count must be > 0. The connection actor will reply with a Tcp.CommandFailed message if the write could not be enqueued. If Tcp.SimpleWriteCommand.wantsAck() returns true, the connection actor will reply with the supplied Tcp.SimpleWriteCommand.ack() token once the write has been successfully enqueued to the O/S kernel. Note that this does not in any way guarantee that the data will be or have been sent! Unfortunately there is no way to determine whether a particular write has been sent by the O/S.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
WritePath(Path path, long position, long count, Tcp.Event ack)

Method Summary

Modifier and Type	Method	Description
Tcp.Event	ack()	The acknowledgment token associated with this write command.
boolean	canEqual(Object x$1)
Tcp.WritePath	copy(Path path, long position, long count, Tcp.Event ack)
Path	copy$default$1()
long	copy$default$2()
long	copy$default$3()
Tcp.Event	copy$default$4()
long	count()
boolean	equals(Object x$1)
int	hashCode()
Path	path()
long	position()
int	productArity()
Object	productElement(int x$1)
String	productElementName(int x$1)
scala.collection.Iterator<Object>	productIterator()
String	productPrefix()
String	toString()

Methods inherited from class org.apache.pekko.io.Tcp.SimpleWriteCommand

append, wantsAck

Methods inherited from class org.apache.pekko.io.Tcp.WriteCommand

$plus$colon, $plus$plus$colon, prepend, prepend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.Product

productElementNames

Methods inherited from interface org.apache.pekko.io.Tcp.Command

failureMessage

Constructor Details

WritePath

public WritePath(Path path,
 long position,
 long count,
 Tcp.Event ack)

Method Details

path

public Path path()

position

public long position()

count

public long count()

ack

public Tcp.Event ack()

Description copied from class: Tcp.SimpleWriteCommand

The acknowledgment token associated with this write command.

Specified by:

ack in class Tcp.SimpleWriteCommand

copy

public Tcp.WritePath copy(Path path,
 long position,
 long count,
 Tcp.Event ack)

copy$default$1

public Path copy$default$1()

copy$default$2

public long copy$default$2()

copy$default$3

public long copy$default$3()

copy$default$4

public Tcp.Event copy$default$4()

productPrefix

public String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(Object x$1)

Specified by:

canEqual in interface scala.Equals

productElementName

public String productElementName(int x$1)

Specified by:

productElementName in interface scala.Product

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class Object