pub mod reqwest;

use std::future::Future;

use futures_core::Stream;

use crate::{codec::ConnectCodec, error::Error, stream::Frame, Request, Response};

pub trait ConnectChannel {
    fn unary_call<T, U>(
        &self,
        method: &str,
        request: Request<T>,
        codec: &mut impl ConnectCodec<Encode = T, Decode = U>,
    ) -> impl Future<Output = Result<Response<U>, Error>>;

    fn streaming_call<T, U>(
        &self,
        method: &str,
        request: Request<impl Stream<Item = Frame<T>> + Send>,
        codec: &mut impl ConnectCodec<Encode = T, Decode = U>,
    ) -> impl Future<Output = Result<Response<impl Stream<Item = Frame<U>>>, Error>>;
}