Struct FCGIWriter

pub struct FCGIWriter<RW> { /* private fields */ }

Available on crate feature codec only.

Implementations

impl<RW: AsyncRead + AsyncWrite + Unpin> FCGIWriter<RW>

pub fn new(io: RW) -> FCGIWriter<RW>

impl<W: AsyncWrite + Unpin> FCGIWriter<W>

pub async fn shutdown(&mut self) -> Result<()>

pub async fn encode(&mut self, item: FCGIType) -> Result<()>

pub async fn data_stream<B>( &mut self, body: B, request_id: u16, rtype: RecordType, len: usize, ) -> Result<()>

where B: Body + Unpin,

Write whole body to the stream

pub async fn flush_data_chunk<B>( &mut self, data: B, request_id: u16, rtype: RecordType, ) -> Result<()>

where B: Buf,

Write data to the stream. Insert header as needed. do not end the data stream

pub fn kv_stream( &mut self, request_id: u16, rtype: RecordType, ) -> NameValuePairWriter<'_, W>

Create a NameValuePairWriter for this stream in order to write key value pairs (like PARAMS).

use tokio::io::AsyncWrite;
use async_fcgi::{fastcgi::RecordType, codec::FCGIWriter};
async fn write_params<W: AsyncWrite+Unpin>(fcgi_writer: &mut FCGIWriter<W>) -> std::io::Result<()> {
    let mut kvw = fcgi_writer.kv_stream(1, RecordType::Params);
    kvw.add_kv(&b"QUERY_STRING"[..], &b""[..]).await?;
    kvw.flush().await?;
    Ok(())
}

See encode_kvp

Trait Implementations

impl<R: AsyncBufRead + Unpin> AsyncBufRead for FCGIWriter<R>

fn poll_fill_buf( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<&[u8]>>

Attempts to return the contents of the internal buffer, filling it with more data from the inner reader if it is empty.

fn consume(self: Pin<&mut Self>, amt: usize)

Tells this buffer that amt bytes have been consumed from the buffer, so they should no longer be returned in calls to poll_read.

impl<R: AsyncRead + Unpin> AsyncRead for FCGIWriter<R>

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.