Packages

c

akka.io.Tcp

Connect

final case class Connect(remoteAddress: InetSocketAddress, localAddress: Option[InetSocketAddress] = None, options: Traversable[SocketOption] = Nil, timeout: Option[FiniteDuration] = None, pullMode: Boolean = false) extends Command with Product with Serializable

The Connect message is sent to the TCP manager actor, which is obtained via TcpExt#manager. Either the manager replies with a CommandFailed or the actor handling the new connection replies with a Connected message.

remoteAddress

is the address to connect to

localAddress

optionally specifies a specific address to bind to

options

Please refer to the Tcp.SO object for a list of all supported options.

Annotations
@nowarn()
Source
Tcp.scala
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Connect
  2. Serializable
  3. Product
  4. Equals
  5. Command
  6. HasFailureMessage
  7. Message
  8. NoSerializationVerificationNeeded
  9. AnyRef
  10. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new Connect(remoteAddress: InetSocketAddress, localAddress: Option[InetSocketAddress] = None, options: Traversable[SocketOption] = Nil, timeout: Option[FiniteDuration] = None, pullMode: Boolean = false)

    remoteAddress

    is the address to connect to

    localAddress

    optionally specifies a specific address to bind to

    options

    Please refer to the Tcp.SO object for a list of all supported options.

Value Members

  1. def failureMessage: CommandFailed
    Definition Classes
    Command → HasFailureMessage
  2. val localAddress: Option[InetSocketAddress]
  3. val options: Traversable[SocketOption]
  4. def productElementNames: Iterator[String]
    Definition Classes
    Product
  5. val pullMode: Boolean
  6. val remoteAddress: InetSocketAddress
  7. val timeout: Option[FiniteDuration]