use sqlx_core::error::Error;
use super::worker::ConnectionWorker;
use crate::{FbConnectOptions, FbConnection};
impl FbConnection {
pub(crate) async fn establish(options: &FbConnectOptions) -> Result<Self, Error> {
let worker = ConnectionWorker::establish(options.clone()).await?;
Ok(Self {
worker,
row_channel_size: options.row_channel_size,
})
}
}