Package org.apache.pekko.io

Class Tcp.CompoundWrite

java.lang.Object
org.apache.pekko.io.Tcp.WriteCommand
org.apache.pekko.io.Tcp.CompoundWrite
All Implemented Interfaces:
Serializable, NoSerializationVerificationNeeded, org.apache.pekko.io.SelectionHandler.HasFailureMessage, Tcp.Command, Tcp.Message, scala.collection.immutable.Iterable<Tcp.SimpleWriteCommand>, scala.collection.Iterable<Tcp.SimpleWriteCommand>, scala.collection.IterableFactoryDefaults<Tcp.SimpleWriteCommand,scala.collection.Iterable>, scala.collection.IterableOnce<Tcp.SimpleWriteCommand>, scala.collection.IterableOnceOps<Tcp.SimpleWriteCommand,scala.collection.Iterable,scala.collection.Iterable>, scala.collection.IterableOps<Tcp.SimpleWriteCommand,scala.collection.Iterable,scala.collection.Iterable>, scala.Equals, scala.Product
Enclosing class:
Tcp
public static final class Tcp.CompoundWrite extends Tcp.WriteCommand implements scala.collection.immutable.Iterable<Tcp.SimpleWriteCommand>, scala.Product, Serializable
A write command which aggregates two other write commands. Using this construct you can chain a number of Tcp.Write and/or WriteFile commands together in a way that allows them to be handled as a single write which gets written out to the network as quickly as possible. If the sub commands contain ack requests they will be honored as soon as the respective write has been written completely.
See Also:

  • Nested Class Summary

    Nested classes/interfaces inherited from interface scala.collection.IterableOps

    scala.collection.IterableOps.SizeCompareOps, scala.collection.IterableOps.SizeCompareOps$, scala.collection.IterableOps.WithFilter<A extends Object,CC extends Object>

  • Constructor Summary

    Constructors
    Constructor
    Description
    CompoundWrite(Tcp.SimpleWriteCommand head, Tcp.WriteCommand tailCommand)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    canEqual(Object x$1)
     
    Tcp.CompoundWrite
    copy(Tcp.SimpleWriteCommand head, Tcp.WriteCommand tailCommand)
     
    Tcp.SimpleWriteCommand
    copy$default$1()
     
    Tcp.WriteCommand
    copy$default$2()
     
    boolean
    equals(Object x$1)
     
    int
    hashCode()
     
    Tcp.SimpleWriteCommand
    head()
     
    scala.collection.Iterator<Tcp.SimpleWriteCommand>
    iterator()
     
    int
    productArity()
     
    Object
    productElement(int x$1)
     
    String
    productElementName(int x$1)
     
    scala.collection.Iterator<Object>
    productIterator()
     
    String
    productPrefix()
     
    Tcp.WriteCommand
    tailCommand()
     

    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, toString, wait, wait, wait

    Methods inherited from interface scala.collection.immutable.Iterable

    iterableFactory

    Methods inherited from interface scala.collection.Iterable

    className, coll, collectionClassName, lazyZip, seq, stringPrefix, toIterable, toString

    Methods inherited from interface scala.collection.IterableFactoryDefaults

    empty, fromSpecific, newSpecificBuilder

    Methods inherited from interface scala.collection.IterableOnce

    knownSize, stepper

    Methods inherited from interface scala.collection.IterableOnceOps

    $colon$bslash, $div$colon, addString, addString, addString, aggregate, collectFirst, copyToArray, copyToArray, copyToArray, copyToBuffer, corresponds, count, exists, find, fold, foldLeft, foldRight, forall, foreach, hasDefiniteSize, isEmpty, max, maxBy, maxByOption, maxOption, min, minBy, minByOption, minOption, mkString, mkString, mkString, nonEmpty, product, reduce, reduceLeft, reduceLeftOption, reduceOption, reduceRight, reduceRightOption, reversed, size, sum, to, toArray, toBuffer, toIndexedSeq, toIterator, toList, toMap, toSeq, toSet, toStream, toVector

    Methods inherited from interface scala.collection.IterableOps

    $plus$plus, $plus$plus$colon, collect, companion, concat, drop, dropRight, dropWhile, filter, filterNot, flatMap, flatten, groupBy, grouped, groupMap, groupMapReduce, headOption, init, inits, isTraversableAgain, last, lastOption, map, partition, partitionMap, repr, scan, scanLeft, scanRight, sizeCompare, sizeCompare, sizeIs, slice, sliding, sliding, span, splitAt, tail, tails, take, takeRight, takeWhile, tapEach, toTraversable, transpose, unzip, unzip3, view, view, withFilter, zip, zipAll, zipWithIndex

    Methods inherited from interface scala.Product

    productElementNames

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

    failureMessage

  • Constructor Details

  • Method Details

    • head

      public Tcp.SimpleWriteCommand head()
      Specified by:
      head in interface scala.collection.IterableOps<Tcp.SimpleWriteCommand,scala.collection.Iterable,scala.collection.Iterable>

    • tailCommand

      public Tcp.WriteCommand tailCommand()

    • iterator

      public scala.collection.Iterator<Tcp.SimpleWriteCommand> iterator()
      Specified by:
      iterator in interface scala.collection.IterableOnce<Tcp.SimpleWriteCommand>

    • copy

      public Tcp.CompoundWrite copy(Tcp.SimpleWriteCommand head, Tcp.WriteCommand tailCommand)

    • copy$default$1

      public Tcp.SimpleWriteCommand copy$default$1()

    • copy$default$2

      public Tcp.WriteCommand copy$default$2()

    • 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

    • equals

      public boolean equals(Object x$1)
      Specified by:
      equals in interface scala.Equals
      Overrides:
      equals in class Object