deboa-extras 0.0.9-beta.11

deboa extras (serialization, compression, websockets, streams, catchers (middleware) and sse support).
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
35
36
37
38
39

use deboa::{
    request::{DeboaRequest, DeboaRequestBuilder},
    url::IntoUrl,
    Result,
};
use http::{header, Method};
use mime_typed::{MimeStrExt, TextEventStream};

/// Trait to convert a DeboaRequestBuilder into a SSE request.
pub trait ServerSentEventBuilder {
    /// Converts a DeboaRequestBuilder into a SSE request.
    ///
    /// # Returns
    ///
    /// A DeboaRequestBuilder.
    ///
    /// # Examples
    ///
    /// ``` compile_fail
    /// use deboa::{Deboa, Result, request::{IntoUrl, DeboaRequestBuilder}};
    /// use deboa_extras::http::sse::request::{ServerSentEventBuilder};
    ///
    /// let mut client = Deboa::default();
    /// let request = DeboaRequestBuilder::sse("https://sse.dev/test").unwrap();
    /// let response = request.send_with(&mut client).await.unwrap();
    /// let event_stream = response.into_event_stream().unwrap();
    /// while let Some(event) = event_stream.next().await {
    ///     println!("event: {}", event);
    /// }
    /// ```
    fn sse<T: IntoUrl>(url: T) -> Result<DeboaRequestBuilder>;
}

impl ServerSentEventBuilder for DeboaRequestBuilder {
    fn sse<T: IntoUrl>(url: T) -> Result<DeboaRequestBuilder> {
        Ok(DeboaRequest::at(url, Method::GET)?
            .header(header::CONTENT_TYPE, TextEventStream::MIME_STR))
    }
}