Class Tcp.IncomingConnection

  • Enclosing class:
    Tcp

    public static class Tcp.IncomingConnection
    extends java.lang.Object
    Represents an accepted incoming TCP connection.
    • Method Detail

      • flow

        public Flow<ByteString,​ByteString,​NotUsed> flow()
        A flow representing the client on the other side of the connection. This flow can be materialized only once.
        Returns:
        (undocumented)
      • handleWith

        public <Mat> Mat handleWith​(Flow<ByteString,​ByteString,​Mat> handler,
                                    Materializer materializer)
        Handles the connection using the given flow, which is materialized exactly once and the respective materialized value is returned.

        Convenience shortcut for: flow.join(handler).run().

        Parameters:
        handler - (undocumented)
        materializer - (undocumented)
        Returns:
        (undocumented)
      • localAddress

        public java.net.InetSocketAddress localAddress()
        The local address this connection is bound to.
        Returns:
        (undocumented)
      • remoteAddress

        public java.net.InetSocketAddress remoteAddress()
        The remote address this connection is bound to.
        Returns:
        (undocumented)