refactor(client): remove Unpin requirement on Body::Data
This commit is contained in:
@@ -385,7 +385,6 @@ impl<T, B> Future for Connection<T, B>
|
|||||||
where
|
where
|
||||||
T: AsyncRead + AsyncWrite + Unpin + Send + 'static,
|
T: AsyncRead + AsyncWrite + Unpin + Send + 'static,
|
||||||
B: Payload + Unpin + 'static,
|
B: Payload + Unpin + 'static,
|
||||||
B::Data: Unpin,
|
|
||||||
{
|
{
|
||||||
type Output = crate::Result<()>;
|
type Output = crate::Result<()>;
|
||||||
|
|
||||||
@@ -521,7 +520,6 @@ impl Builder {
|
|||||||
where
|
where
|
||||||
T: AsyncRead + AsyncWrite + Unpin + Send + 'static,
|
T: AsyncRead + AsyncWrite + Unpin + Send + 'static,
|
||||||
B: Payload + 'static,
|
B: Payload + 'static,
|
||||||
B::Data: Unpin,
|
|
||||||
{
|
{
|
||||||
let opts = self.clone();
|
let opts = self.clone();
|
||||||
|
|
||||||
@@ -594,7 +592,6 @@ impl<T, B> Future for ProtoClient<T, B>
|
|||||||
where
|
where
|
||||||
T: AsyncRead + AsyncWrite + Send + Unpin + 'static,
|
T: AsyncRead + AsyncWrite + Send + Unpin + 'static,
|
||||||
B: Payload + Unpin + 'static,
|
B: Payload + Unpin + 'static,
|
||||||
B::Data: Unpin,
|
|
||||||
{
|
{
|
||||||
type Output = crate::Result<proto::Dispatched>;
|
type Output = crate::Result<proto::Dispatched>;
|
||||||
|
|
||||||
|
|||||||
@@ -153,7 +153,7 @@ where
|
|||||||
C::Transport: Unpin + Send + 'static,
|
C::Transport: Unpin + Send + 'static,
|
||||||
C::Future: Unpin + Send + 'static,
|
C::Future: Unpin + Send + 'static,
|
||||||
B: Payload + Unpin + Send + 'static,
|
B: Payload + Unpin + Send + 'static,
|
||||||
B::Data: Send + Unpin,
|
B::Data: Send,
|
||||||
{
|
{
|
||||||
/// Send a `GET` request to the supplied `Uri`.
|
/// Send a `GET` request to the supplied `Uri`.
|
||||||
///
|
///
|
||||||
@@ -551,7 +551,7 @@ where
|
|||||||
C::Transport: Unpin + Send + 'static,
|
C::Transport: Unpin + Send + 'static,
|
||||||
C::Future: Unpin + Send + 'static,
|
C::Future: Unpin + Send + 'static,
|
||||||
B: Payload + Unpin + Send + 'static,
|
B: Payload + Unpin + Send + 'static,
|
||||||
B::Data: Send + Unpin,
|
B::Data: Send,
|
||||||
{
|
{
|
||||||
type Response = Response<Body>;
|
type Response = Response<Body>;
|
||||||
type Error = crate::Error;
|
type Error = crate::Error;
|
||||||
|
|||||||
@@ -31,7 +31,6 @@ pub(crate) async fn handshake<T, B>(
|
|||||||
where
|
where
|
||||||
T: AsyncRead + AsyncWrite + Send + Unpin + 'static,
|
T: AsyncRead + AsyncWrite + Send + Unpin + 'static,
|
||||||
B: Payload,
|
B: Payload,
|
||||||
B::Data: Unpin,
|
|
||||||
{
|
{
|
||||||
let (h2_tx, conn) = builder
|
let (h2_tx, conn) = builder
|
||||||
.handshake::<_, SendBuf<B::Data>>(io)
|
.handshake::<_, SendBuf<B::Data>>(io)
|
||||||
@@ -93,7 +92,6 @@ where
|
|||||||
impl<B> Future for ClientTask<B>
|
impl<B> Future for ClientTask<B>
|
||||||
where
|
where
|
||||||
B: Payload + Unpin + 'static,
|
B: Payload + Unpin + 'static,
|
||||||
B::Data: Unpin,
|
|
||||||
{
|
{
|
||||||
type Output = crate::Result<Dispatched>;
|
type Output = crate::Result<Dispatched>;
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user