We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 37a7b49 commit 697e59eCopy full SHA for 697e59e
capnp-futures/src/read_stream.rs
@@ -37,22 +37,17 @@ where
37
Ok((reader, m))
38
}
39
40
+type ReadStreamResult<R> =
41
+ Result<(R, Option<message::Reader<capnp::serialize::OwnedSegments>>), Error>;
42
+
43
+/// An incoming sequence of messages.
44
#[must_use = "streams do nothing unless polled"]
45
pub struct ReadStream<'a, R>
46
where
47
R: AsyncRead + Unpin,
48
{
49
options: message::ReaderOptions,
- read: Pin<
- Box<
- dyn Future<
- Output = Result<
50
- (R, Option<message::Reader<capnp::serialize::OwnedSegments>>),
51
- Error,
52
- >,
53
- > + 'a,
54
55
+ read: Pin<Box<dyn Future<Output = ReadStreamResult<R>> + 'a>>,
56
57
58
impl<'a, R> Unpin for ReadStream<'a, R> where R: AsyncRead + Unpin {}
0 commit comments