smtp_reply_parser_set_stream(conn->reply_parser,
conn->conn.input);
}
+
+ connection_streams_changed(&conn->conn);
}
static int
conn->conn.output = conn->raw_output;
}
+ io_remove(&conn->conn.io);
if (io_stream_create_ssl_client(conn->ssl_ctx,
conn->host, conn->set.ssl,
&conn->conn.input, &conn->conn.output,
conn->conn.name, error);
return -1;
}
+ conn->conn.io = io_add_istream(conn->conn.input,
+ smtp_client_connection_input,
+ &conn->conn);
smtp_client_connection_streams_changed(conn);
ssl_iostream_set_handshake_callback(conn->ssl_iostream,