akka.io

Class Tcp.CompoundWrite

java.lang.Object

akka.io.Tcp.WriteCommand

akka.io.Tcp.CompoundWrite

All Implemented Interfaces:

NoSerializationVerificationNeeded, SelectionHandler.HasFailureMessage, Tcp.Command, Tcp.Message, java.io.Serializable, scala.collection.generic.FilterMonadic<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>, scala.collection.generic.GenericTraversableTemplate<Tcp.SimpleWriteCommand,scala.collection.GenTraversable>, scala.collection.generic.HasNewBuilder<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>, scala.collection.GenIterable<Tcp.SimpleWriteCommand>, scala.collection.GenIterableLike<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>, scala.collection.GenTraversable<Tcp.SimpleWriteCommand>, scala.collection.GenTraversableLike<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>, scala.collection.GenTraversableOnce<Tcp.SimpleWriteCommand>, scala.collection.Iterable<Tcp.SimpleWriteCommand>, scala.collection.IterableLike<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>, scala.collection.Parallelizable<Tcp.SimpleWriteCommand,scala.collection.parallel.ParIterable<Tcp.SimpleWriteCommand>>, scala.collection.Traversable<Tcp.SimpleWriteCommand>, scala.collection.TraversableLike<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>, scala.collection.TraversableOnce<Tcp.SimpleWriteCommand>, scala.Equals, scala.Immutable, scala.Product

Enclosing class:

Tcp

public static final class Tcp.CompoundWrite
extends Tcp.WriteCommand
implements scala.collection.immutable.Iterable<Tcp.SimpleWriteCommand>, scala.Product, scala.Serializable

A write command which aggregates two other write commands. Using this construct you can chain a number of Tcp.Write and/or Tcp.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:

Serialized Form

Nested Class Summary

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

scala.collection.TraversableLike.WithFilter

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

scala.collection.TraversableOnce.BufferedCanBuildFrom<A,CC extends scala.collection.TraversableOnce<java.lang.Object>>, scala.collection.TraversableOnce.FlattenOps<A>, scala.collection.TraversableOnce.ForceImplicitAmbiguity, scala.collection.TraversableOnce.MonadOps<A>, scala.collection.TraversableOnce.OnceCanBuildFrom<A>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Tcp.SimpleWriteCommand	head()
scala.collection.Iterator<Tcp.SimpleWriteCommand>	iterator()
Tcp.WriteCommand	tailCommand()

Methods inherited from class akka.io.Tcp.WriteCommand

prepend, prepend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.collection.immutable.Iterable

companion, parCombiner, seq

Methods inherited from interface scala.collection.generic.GenericTraversableTemplate

flatten, foreach, genericBuilder, isEmpty, transpose, unzip, unzip3

Methods inherited from interface scala.collection.IterableLike

canEqual, copyToArray, drop, dropRight, exists, find, foldRight, forall, foreach, grouped, isEmpty, reduceRight, sameElements, slice, sliding, sliding, take, takeRight, takeWhile, thisCollection, toCollection, toIterable, toIterator, toStream, view, view, zip, zipAll, zipWithIndex

Methods inherited from interface scala.Equals

equals

Methods inherited from interface scala.collection.TraversableLike

$plus$plus, $plus$plus$colon, $plus$plus$colon, collect, dropWhile, filter, filterNot, flatMap, groupBy, hasDefiniteSize, headOption, init, inits, isTraversableAgain, last, lastOption, map, newBuilder, partition, repr, scan, scanLeft, scanRight, sliceWithKnownBound, sliceWithKnownDelta, span, splitAt, stringPrefix, tail, tails, to, toString, toTraversable, withFilter

Methods inherited from interface scala.collection.TraversableOnce

$colon$bslash, $div$colon, addString, addString, addString, aggregate, collectFirst, copyToArray, copyToArray, copyToBuffer, count, fold, foldLeft, max, maxBy, min, minBy, mkString, mkString, mkString, nonEmpty, product, reduce, reduceLeft, reduceLeftOption, reduceOption, reduceRightOption, reversed, size, sum, toArray, toBuffer, toIndexedSeq, toList, toMap, toSeq, toSet, toVector

Methods inherited from interface scala.collection.GenTraversableLike

size

Methods inherited from interface scala.collection.Parallelizable

par

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface akka.io.Tcp.Command

failureMessage

Constructor Detail

CompoundWrite

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

Method Detail

head

public Tcp.SimpleWriteCommand head()

Specified by:

head in interface scala.collection.generic.GenericTraversableTemplate<Tcp.SimpleWriteCommand,scala.collection.GenTraversable>

Specified by:

head in interface scala.collection.GenTraversableLike<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>

Specified by:

head in interface scala.collection.IterableLike<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>

Specified by:

head in interface scala.collection.TraversableLike<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>

tailCommand

public Tcp.WriteCommand tailCommand()

iterator

public scala.collection.Iterator<Tcp.SimpleWriteCommand> iterator()

Specified by:

iterator in interface scala.collection.GenIterableLike<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>

Specified by:

iterator in interface scala.collection.IterableLike<Tcp.SimpleWriteCommand,scala.collection.Iterable<Tcp.SimpleWriteCommand>>