class RpcStreamConnection extends RpcConnection {

    void processNameArgs(@Nonnull RpcPacket packet,
            @Nonnull final RpcPacketSupplier argsSupplier) {
        Map<String, Object> mapArgs = packet.getMapArgs();
        if (nonNull(mapArgs)) {
            for (Map.Entry<String, Object> entry : mapArgs.entrySet()) {
                reallocateSendBufferInPutPacketIfRunOut(argsSupplier,
                        marshalPacketField(entry.getKey(), entry.getValue()), SENDBUF_REALLOC_INCR);
            }
        }
    }

    public  RpcStreamConnection(String serverHost, int serverPort, Properties props,
                               ServerStats stats, P4Charset p4Charset, boolean secure);
    private  RpcStreamConnection(String serverHost, int serverPort, Properties props,
            ServerStats stats, P4Charset p4Charset, Socket socket, boolean secure);
    private  RpcStreamConnection(String serverHost, int serverPort, Properties props,
            ServerStats stats, P4Charset p4Charset, Socket socket, RpcSocketPool pool, boolean secure);
    public  RpcStreamConnection(String serverHost, int serverPort, Properties props,
            ServerStats stats, P4Charset p4Charset, Socket socket, RpcSocketPool pool, boolean secure,
            String rsh);

}