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.
      • handleWith

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

        Convenience shortcut for: flow.joinMat(handler, Keep.right).run(systemProvider).

        Note that the classic or typed ActorSystem can be used as the systemProvider parameter.

      • 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.joinMat(handler, Keep.right).run(materializer).

        Prefer the method taking an ActorSystem unless you have special requirements

      • localAddress

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

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