async-sse 2.1.0

Async Server Sent Event parser and encoder
Documentation
Build #227222 2020-03-04T23:55:42.551040+00:00
# rustc version
rustc 1.43.0-nightly (4ad624882 2020-03-03)# docs.rs version
docsrs 0.6.0 (be4a0c1 2020-03-04)# build log
[INFO] running `"docker" "create" "-v" "/home/cratesfyi/workspace/builds/async-sse-2.1.0/target:/opt/rustwide/target:rw,Z" "-v" "/home/cratesfyi/workspace/builds/async-sse-2.1.0/source:/opt/rustwide/workdir:ro,Z" "-v" "/home/cratesfyi/workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/home/cratesfyi/workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "MAP_USER_ID=1001" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "RUSTFLAGS=" "-e" "RUSTDOCFLAGS=-Z unstable-options --resource-suffix -20200303-1.43.0-nightly-4ad624882 --static-root-path / --extern-html-root-url async_std=https://docs.rs/async-std/1.5.0 --extern-html-root-url memchr=https://docs.rs/memchr/2.3.3 --extern-html-root-url http_types=https://docs.rs/http-types/1.0.1 --extern-html-root-url pin_project_lite=https://docs.rs/pin-project-lite/0.1.4 --extern-html-root-url femme=https://docs.rs/femme/1.3.0 --extern-html-root-url log=https://docs.rs/log/0.4.8" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "3221225472" "--network" "none" "rustops/crates-build-env" "/opt/rustwide/cargo-home/bin/cargo" "+nightly" "doc" "--lib" "--no-deps"`
[INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
[INFO] [stdout] 28d2356994392db5ca0f392ded50956c262ea42275988e6d690f2f77f5f9d3e1
[INFO] running `"docker" "start" "-a" "28d2356994392db5ca0f392ded50956c262ea42275988e6d690f2f77f5f9d3e1"`
[INFO] [stderr]    Compiling libc v0.2.67
[INFO] [stderr]     Checking cfg-if v0.1.10
[INFO] [stderr]    Compiling proc-macro2 v1.0.9
[INFO] [stderr]    Compiling autocfg v1.0.0
[INFO] [stderr]    Compiling unicode-xid v0.2.0
[INFO] [stderr]    Compiling syn v1.0.16
[INFO] [stderr]    Compiling semver-parser v0.7.0
[INFO] [stderr]     Checking smallvec v1.2.0
[INFO] [stderr]    Compiling maybe-uninit v2.0.0
[INFO] [stderr]     Checking scopeguard v1.1.0
[INFO] [stderr]    Compiling log v0.4.8
[INFO] [stderr]     Checking lazy_static v1.4.0
[INFO] [stderr]     Checking slab v0.4.2
[INFO] [stderr]    Compiling proc-macro-nested v0.1.3
[INFO] [stderr]     Checking futures-sink v0.3.4
[INFO] [stderr]     Checking futures-core v0.3.4
[INFO] [stderr]    Compiling memchr v2.3.3
[INFO] [stderr]    Compiling byteorder v1.3.4
[INFO] [stderr]     Checking matches v0.1.8
[INFO] [stderr]     Checking futures-task v0.3.4
[INFO] [stderr]     Checking pin-utils v0.1.0-alpha.4
[INFO] [stderr]    Compiling anyhow v1.0.26
[INFO] [stderr]     Checking percent-encoding v2.1.0
[INFO] [stderr]     Checking futures-io v0.3.4
[INFO] [stderr]     Checking futures-timer v2.0.2
[INFO] [stderr]     Checking pin-project-lite v0.1.4
[INFO] [stderr]     Checking once_cell v1.3.1
[INFO] [stderr]    Compiling semver v0.9.0
[INFO] [stderr]     Checking unicode-normalization v0.1.12
[INFO] [stderr]     Checking lock_api v0.3.3
[INFO] [stderr]    Compiling crossbeam-utils v0.7.2
[INFO] [stderr]    Compiling crossbeam-epoch v0.8.2
[INFO] [stderr]     Checking futures-channel v0.3.4
[INFO] [stderr]     Checking unicode-bidi v0.3.4
[INFO] [stderr]    Compiling rustc_version v0.2.3
[INFO] [stderr]     Checking idna v0.2.0
[INFO] [stderr]    Compiling quote v1.0.2
[INFO] [stderr]     Checking kv-log-macro v1.0.4
[INFO] [stderr]     Checking net2 v0.2.33
[INFO] [stderr]     Checking parking_lot_core v0.7.0
[INFO] [stderr]     Checking iovec v0.1.4
[INFO] [stderr]     Checking async-task v1.3.1
[INFO] [stderr]     Checking time v0.1.42
[INFO] [stderr]     Checking num_cpus v1.12.0
[INFO] [stderr]    Compiling memoffset v0.5.3
[INFO] [stderr]     Checking omnom v2.1.2
[INFO] [stderr]     Checking infer v0.1.4
[INFO] [stderr]     Checking crossbeam-channel v0.4.2
[INFO] [stderr]     Checking url v2.1.1
[INFO] [stderr]     Checking mio v0.6.21
[INFO] [stderr]     Checking parking_lot v0.10.0
[INFO] [stderr]     Checking cookie v0.12.0
[INFO] [stderr]     Checking mio-uds v0.6.7
[INFO] [stderr]     Checking crossbeam-deque v0.7.3
[INFO] [stderr]    Compiling proc-macro-hack v0.5.11
[INFO] [stderr]    Compiling async-attributes v1.1.1
[INFO] [stderr]    Compiling futures-macro v0.3.4
[INFO] [stderr]     Checking futures-util v0.3.4
[INFO] [stderr]     Checking broadcaster v1.0.0
[INFO] [stderr]     Checking async-std v1.5.0
[INFO] [stderr]     Checking http-types v1.0.1
[INFO] [stderr]  Documenting async-sse v2.1.0 (/opt/rustwide/workdir)
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/decoder.rs:25:1
[INFO] [stderr]    |
[INFO] [stderr] 25 | /// An SSE protocol decoder.
[INFO] [stderr]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr] note: the lint level is defined here
[INFO] [stderr]   --> src/lib.rs:36:23
[INFO] [stderr]    |
[INFO] [stderr] 36 | #![warn(missing_docs, missing_doc_code_examples, unreachable_pub)]
[INFO] [stderr]    |                       ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/decoder.rs:28:5
[INFO] [stderr]    |
[INFO] [stderr] 28 |     /// The lines decoder.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/decoder.rs:30:5
[INFO] [stderr]    |
[INFO] [stderr] 30 |     /// Have we processed the optional Byte Order Marker on the first line?
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/decoder.rs:32:5
[INFO] [stderr]    |
[INFO] [stderr] 32 | /     /// Was the last character of the previous line a \r?
[INFO] [stderr] 33 | |     /// Bytes that were fed to the decoder but do not yet form a message.
[INFO] [stderr]    | |_________________________________________________________________________^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/decoder.rs:35:5
[INFO] [stderr]    |
[INFO] [stderr] 35 |     /// The _last event ID_ buffer.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/decoder.rs:37:5
[INFO] [stderr]    |
[INFO] [stderr] 37 |     /// The _event type_ buffer.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/decoder.rs:39:5
[INFO] [stderr]    |
[INFO] [stderr] 39 |     /// The _data_ buffer.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/encoder.rs:81:1
[INFO] [stderr]    |
[INFO] [stderr] 81 | /// The sending side of the encoder.
[INFO] [stderr]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/encoder.rs:83:19
[INFO] [stderr]    |
[INFO] [stderr] 83 | pub struct Sender(sync::Sender<Vec<u8>>);
[INFO] [stderr]    |                   ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]  --> src/message.rs:1:1
[INFO] [stderr]   |
[INFO] [stderr] 1 | /// An SSE event with a data payload.
[INFO] [stderr]   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]  --> src/message.rs:4:5
[INFO] [stderr]   |
[INFO] [stderr] 4 | /     /// The ID of this event.
[INFO] [stderr] 5 | |     ///
[INFO] [stderr] 6 | |     /// See also the [Server-Sent Events spec](https://html.spec.whatwg.org/multipage/server-sent-events.html#concept-event-stream-last-event-id).
[INFO] [stderr]   | |__________________________________________________________________________________________________________________________________________________^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]  --> src/message.rs:8:5
[INFO] [stderr]   |
[INFO] [stderr] 8 |     /// The event name. Defaults to "message" if no event name is provided.
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/message.rs:10:5
[INFO] [stderr]    |
[INFO] [stderr] 10 |     /// The data for this event.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]  --> src/event.rs:5:1
[INFO] [stderr]   |
[INFO] [stderr] 5 | /// The kind of SSE event sent.
[INFO] [stderr]   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]  --> src/event.rs:8:5
[INFO] [stderr]   |
[INFO] [stderr] 8 |     /// A retry frame, signaling a new retry duration must be used..
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/event.rs:10:5
[INFO] [stderr]    |
[INFO] [stderr] 10 |     /// A data frame containing a message.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/decoder.rs:10:1
[INFO] [stderr]    |
[INFO] [stderr] 10 | /// Decode a new incoming SSE connection.
[INFO] [stderr]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/encoder.rs:85:1
[INFO] [stderr]    |
[INFO] [stderr] 85 | /// Create a new SSE encoder.
[INFO] [stderr]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]  --> src/handshake.rs:1:1
[INFO] [stderr]   |
[INFO] [stderr] 1 | /// Upgrade an HTTP connection into an SSE session.
[INFO] [stderr]   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]    --> src/decoder.rs:1:1
[INFO] [stderr]     |
[INFO] [stderr] 1   | / use async_std::io::BufRead as AsyncBufRead;
[INFO] [stderr] 2   | | use async_std::stream::Stream;
[INFO] [stderr] 3   | | use async_std::task::{self, Context, Poll};
[INFO] [stderr] 4   | |
[INFO] [stderr] ...   |
[INFO] [stderr] 163 | |     }
[INFO] [stderr] 164 | | }
[INFO] [stderr]     | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/decoder.rs:25:1
[INFO] [stderr]    |
[INFO] [stderr] 25 | /// An SSE protocol decoder.
[INFO] [stderr]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]    --> src/encoder.rs:1:1
[INFO] [stderr]     |
[INFO] [stderr] 1   | / use async_std::sync;
[INFO] [stderr] 2   | | use std::io;
[INFO] [stderr] 3   | | use std::time::Duration;
[INFO] [stderr] 4   | |
[INFO] [stderr] ...   |
[INFO] [stderr] 132 | |     }
[INFO] [stderr] 133 | | }
[INFO] [stderr]     | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]    --> src/encoder.rs:96:1
[INFO] [stderr]     |
[INFO] [stderr] 96  | / impl Sender {
[INFO] [stderr] 97  | |     /// Send a new message over SSE.
[INFO] [stderr] 98  | |     pub async fn send(&self, name: &str, data: &[u8], id: Option<&str>) {
[INFO] [stderr] 99  | |         // Write the event name
[INFO] [stderr] ...   |
[INFO] [stderr] 126 | |     }
[INFO] [stderr] 127 | | }
[INFO] [stderr]     | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/encoder.rs:97:5
[INFO] [stderr]    |
[INFO] [stderr] 97 |     /// Send a new message over SSE.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]    --> src/encoder.rs:115:5
[INFO] [stderr]     |
[INFO] [stderr] 115 |     /// Send a new "retry" message over SSE.
[INFO] [stderr]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/event.rs:1:1
[INFO] [stderr]    |
[INFO] [stderr] 1  | / use crate::Message;
[INFO] [stderr] 2  | |
[INFO] [stderr] 3  | | use std::time::Duration;
[INFO] [stderr] 4  | |
[INFO] [stderr] ...  |
[INFO] [stderr] 39 | |     }
[INFO] [stderr] 40 | | }
[INFO] [stderr]    | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/event.rs:14:1
[INFO] [stderr]    |
[INFO] [stderr] 14 | / impl Event {
[INFO] [stderr] 15 | |     /// Create a new message.
[INFO] [stderr] 16 | |     pub(crate) fn new_msg(name: String, data: Vec<u8>, id: Option<String>) -> Self {
[INFO] [stderr] 17 | |         Self::Message(Message { name, data, id })
[INFO] [stderr] ...  |
[INFO] [stderr] 39 | |     }
[INFO] [stderr] 40 | | }
[INFO] [stderr]    | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/event.rs:25:5
[INFO] [stderr]    |
[INFO] [stderr] 25 |     /// Check whether this is a Retry variant.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/event.rs:33:5
[INFO] [stderr]    |
[INFO] [stderr] 33 |     /// Check whether this is a `Message` variant.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]  --> src/handshake.rs:1:1
[INFO] [stderr]   |
[INFO] [stderr] 1 | / /// Upgrade an HTTP connection into an SSE session.
[INFO] [stderr] 2 | | pub fn upgrade(headers: &mut impl AsMut<http_types::Headers>) -> http_types::Result<()> {
[INFO] [stderr] 3 | |     let headers = headers.as_mut();
[INFO] [stderr] 4 | |     headers.insert("Cache-Control", "no-cache")?;
[INFO] [stderr] 5 | |     headers.insert("Content-Type", "text/event-stream")?;
[INFO] [stderr] 6 | |     Ok(())
[INFO] [stderr] 7 | | }
[INFO] [stderr]   | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]    --> src/lines.rs:1:1
[INFO] [stderr]     |
[INFO] [stderr] 1   | / use std::mem;
[INFO] [stderr] 2   | | use std::pin::Pin;
[INFO] [stderr] 3   | | use std::str;
[INFO] [stderr] 4   | |
[INFO] [stderr] ...   |
[INFO] [stderr] 120 | |     }
[INFO] [stderr] 121 | | }
[INFO] [stderr]     | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/message.rs:1:1
[INFO] [stderr]    |
[INFO] [stderr] 1  | / /// An SSE event with a data payload.
[INFO] [stderr] 2  | | #[derive(Debug, PartialEq, Eq, Hash)]
[INFO] [stderr] 3  | | pub struct Message {
[INFO] [stderr] 4  | |     /// The ID of this event.
[INFO] [stderr] ...  |
[INFO] [stderr] 33 | |     }
[INFO] [stderr] 34 | | }
[INFO] [stderr]    | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/message.rs:14:1
[INFO] [stderr]    |
[INFO] [stderr] 14 | / impl Message {
[INFO] [stderr] 15 | |     /// Get the message id.
[INFO] [stderr] 16 | |     pub fn id(&self) -> &Option<String> {
[INFO] [stderr] 17 | |         &self.id
[INFO] [stderr] ...  |
[INFO] [stderr] 33 | |     }
[INFO] [stderr] 34 | | }
[INFO] [stderr]    | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/message.rs:15:5
[INFO] [stderr]    |
[INFO] [stderr] 15 |     /// Get the message id.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/message.rs:20:5
[INFO] [stderr]    |
[INFO] [stderr] 20 |     /// Get the message event name.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/message.rs:25:5
[INFO] [stderr]    |
[INFO] [stderr] 25 |     /// Access the event data.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/message.rs:30:5
[INFO] [stderr]    |
[INFO] [stderr] 30 |     /// Convert the message into the data payload.
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]    --> src/encoder.rs:129:1
[INFO] [stderr]     |
[INFO] [stderr] 129 | / impl Clone for Sender {
[INFO] [stderr] 130 | |     fn clone(&self) -> Self {
[INFO] [stderr] 131 | |         Self(self.0.clone())
[INFO] [stderr] 132 | |     }
[INFO] [stderr] 133 | | }
[INFO] [stderr]     | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]    --> src/encoder.rs:130:5
[INFO] [stderr]     |
[INFO] [stderr] 130 | /     fn clone(&self) -> Self {
[INFO] [stderr] 131 | |         Self(self.0.clone())
[INFO] [stderr] 132 | |     }
[INFO] [stderr]     | |_____^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/encoder.rs:21:1
[INFO] [stderr]    |
[INFO] [stderr] 21 | / impl AsyncRead for Encoder {
[INFO] [stderr] 22 | |     fn poll_read(
[INFO] [stderr] 23 | |         mut self: Pin<&mut Self>,
[INFO] [stderr] 24 | |         cx: &mut Context<'_>,
[INFO] [stderr] ...  |
[INFO] [stderr] 57 | |     }
[INFO] [stderr] 58 | | }
[INFO] [stderr]    | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/encoder.rs:22:5
[INFO] [stderr]    |
[INFO] [stderr] 22 | /     fn poll_read(
[INFO] [stderr] 23 | |         mut self: Pin<&mut Self>,
[INFO] [stderr] 24 | |         cx: &mut Context<'_>,
[INFO] [stderr] 25 | |         buf: &mut [u8],
[INFO] [stderr] ...  |
[INFO] [stderr] 56 | |         Poll::Ready(Ok(max))
[INFO] [stderr] 57 | |     }
[INFO] [stderr]    | |_____^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]    --> src/decoder.rs:64:1
[INFO] [stderr]     |
[INFO] [stderr] 64  | / impl<R: AsyncBufRead + Unpin> Stream for Decoder<R> {
[INFO] [stderr] 65  | |     type Item = http_types::Result<Event>;
[INFO] [stderr] 66  | |
[INFO] [stderr] 67  | |     // This function uses two loops: one to get lines from the reader.
[INFO] [stderr] ...   |
[INFO] [stderr] 146 | |     }
[INFO] [stderr] 147 | | }
[INFO] [stderr]     | |_^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]   --> src/decoder.rs:65:5
[INFO] [stderr]    |
[INFO] [stderr] 65 |     type Item = http_types::Result<Event>;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr]    --> src/decoder.rs:69:5
[INFO] [stderr]     |
[INFO] [stderr] 69  | /     fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
[INFO] [stderr] 70  | |         loop {
[INFO] [stderr] 71  | |             // Get the next line, if available.
[INFO] [stderr] 72  | |             let line = match task::ready!(Pin::new(&mut self.lines).poll_next(cx)) {
[INFO] [stderr] ...   |
[INFO] [stderr] 145 | |         }
[INFO] [stderr] 146 | |     }
[INFO] [stderr]     | |_____^
[INFO] [stderr] 
[INFO] [stderr] warning: doc comment contains an invalid Rust code block
[INFO] [stderr]     |
[INFO] [stderr]     = help: mark blocks that do not contain Rust code as text: ```text
[INFO] [stderr] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 31.65s
[INFO] running `"docker" "inspect" "28d2356994392db5ca0f392ded50956c262ea42275988e6d690f2f77f5f9d3e1"`
[INFO] running `"docker" "rm" "-f" "28d2356994392db5ca0f392ded50956c262ea42275988e6d690f2f77f5f9d3e1"`
[INFO] [stdout] 28d2356994392db5ca0f392ded50956c262ea42275988e6d690f2f77f5f9d3e1