apollo-router 1.61.13

A configurable, high-performance routing runtime for Apollo Federation 🚀
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

use std::task::Poll;

use futures::Stream;
use pin_project_lite::pin_project;

pin_project! {
    /// Allows conversion between an http_body::Body and a futures stream.
    pub(crate) struct BodyStream<B: http_body::Body> {
        #[pin]
        inner: B
    }
}

impl<B: hyper::body::HttpBody> BodyStream<B> {
    /// Create a new `BodyStream`.
    pub(crate) fn new(body: B) -> Self {
        Self { inner: body }
    }
}

impl<B, D, E> Stream for BodyStream<B>
where
    B: http_body::Body<Data = D, Error = E>,
    B::Error: Into<E>,
{
    type Item = Result<D, E>;

    fn poll_next(
        self: std::pin::Pin<&mut Self>,
        cx: &mut std::task::Context<'_>,
    ) -> Poll<Option<Self::Item>> {
        self.project().inner.poll_data(cx)
    }
}