Struct Client 

pub struct Client<S, M> { /* private fields */ }

Async client for handling communication between fastcgi server.

Implementations

impl<S> Client<TokioCompat<S>, ShortConn>

where S: AsyncRead + AsyncWrite + Unpin,

pub fn new_tokio(stream: S) -> Self

Available on crate feature runtime-tokio only.

Construct a Client Object with a Tokio stream under short connection mode.

Examples

use fastcgi_client::Client;
use tokio::net::TcpStream;

let tcp_stream = TcpStream::connect(("127.0.0.1", 9000)).await.unwrap();
let _tcp_client = Client::new_tokio(tcp_stream);

let unix_stream = UnixStream::connect("/run/php-fpm.sock").await.unwrap();
let _unix_client = Client::new_tokio(unix_stream);

impl<S> Client<S, ShortConn>

where S: AsyncRead + AsyncWrite + Unpin,

pub fn new_smol(stream: S) -> Self

Available on crate feature runtime-smol only.

Construct a Client Object with a Smol-compatible stream under short connection mode.

Examples

use fastcgi_client::Client;
use smol::net::TcpStream;

let tcp_stream = TcpStream::connect(("127.0.0.1", 9000)).await.unwrap();
let _tcp_client = Client::new_smol(tcp_stream);

let unix_stream = UnixStream::connect("/run/php-fpm.sock").await.unwrap();
let _unix_client = Client::new_smol(unix_stream);

impl<S: AsyncRead + AsyncWrite + Unpin> Client<S, ShortConn>

pub async fn execute_once<I: AsyncRead + Unpin>( self, request: Request<'_, I>, ) -> ClientResult<Response>

Send request and receive response from fastcgi server, under short connection mode.

pub async fn execute_once_stream<I: AsyncRead + Unpin>( self, request: Request<'_, I>, ) -> ClientResult<ResponseStream<S>>

Send request and receive response stream from fastcgi server, under short connection mode.

Examples

use fastcgi_client::{io, response::Content, Client, Params, Request, StreamExt};
use tokio::net::TcpStream;

    let stream = TcpStream::connect(("127.0.0.1", 9000)).await.unwrap();
    let client = Client::new_tokio(stream);
    let mut stream = client
        .execute_once_stream(Request::new(Params::default(), io::empty()))
        .await
        .unwrap();

    while let Some(content) = stream.next().await {
        let content = content.unwrap();

        match content {
            Content::Stdout(out) => todo!(),
            Content::Stderr(out) => todo!(),
        }
    }
}

impl<S> Client<TokioCompat<S>, KeepAlive>

where S: AsyncRead + AsyncWrite + Unpin,

pub fn new_keep_alive_tokio(stream: S) -> Self

Available on crate feature runtime-tokio only.

Construct a Client Object with a Tokio stream under keep-alive mode.

Examples

use fastcgi_client::Client;
use tokio::net::TcpStream;

let tcp_stream = TcpStream::connect(("127.0.0.1", 9000)).await.unwrap();
let _tcp_client = Client::new_keep_alive_tokio(tcp_stream);

let unix_stream = UnixStream::connect("/run/php-fpm.sock").await.unwrap();
let _unix_client = Client::new_keep_alive_tokio(unix_stream);

impl<S> Client<S, KeepAlive>

where S: AsyncRead + AsyncWrite + Unpin,

pub fn new_keep_alive_smol(stream: S) -> Self

Available on crate feature runtime-smol only.

Construct a Client Object with a Smol-compatible stream under keep-alive mode.

Examples

use fastcgi_client::Client;
use smol::net::TcpStream;

let tcp_stream = TcpStream::connect(("127.0.0.1", 9000)).await.unwrap();
let _tcp_client = Client::new_keep_alive_smol(tcp_stream);

let unix_stream = UnixStream::connect("/run/php-fpm.sock").await.unwrap();
let _unix_client = Client::new_keep_alive_smol(unix_stream);

impl<S: AsyncRead + AsyncWrite + Unpin> Client<S, KeepAlive>

pub async fn execute<I: AsyncRead + Unpin>( &mut self, request: Request<'_, I>, ) -> ClientResult<Response>

Send request and receive response from fastcgi server, under keep alive connection mode.

pub async fn execute_stream<I: AsyncRead + Unpin>( &mut self, request: Request<'_, I>, ) -> ClientResult<ResponseStream<&mut S>>

Send request and receive response stream from fastcgi server, under keep alive connection mode.

Examples

use fastcgi_client::{io, response::Content, Client, Params, Request, StreamExt};
use tokio::net::TcpStream;

    let stream = TcpStream::connect(("127.0.0.1", 9000)).await.unwrap();
    let mut client = Client::new_keep_alive_tokio(stream);

    for _ in (0..3) {
        let mut stream = client
            .execute_stream(Request::new(Params::default(), io::empty()))
            .await
            .unwrap();

        while let Some(content) = stream.next().await {
            let content = content.unwrap();

            match content {
                Content::Stdout(out) => todo!(),
                Content::Stderr(out) => todo!(),
            }
        }
    }
}