diff --git a/libsignal-service/src/messagepipe.rs b/libsignal-service/src/messagepipe.rs index a81dfb7bd..46303ce2e 100644 --- a/libsignal-service/src/messagepipe.rs +++ b/libsignal-service/src/messagepipe.rs @@ -124,6 +124,8 @@ impl MessagePipe { } /// Returns the stream of `Envelope`s + /// + /// Envelopes yielded are acknowledged. pub fn stream(self) -> impl Stream> { let (sink, stream) = mpsc::channel(1);