Struct poem_openapi::payload::EventStream
source · pub struct EventStream<T: Stream + Send + 'static> { /* private fields */ }Expand description
An event stream payload.
Reference: https://github.com/OAI/OpenAPI-Specification/issues/396#issuecomment-894718960
Implementations§
source§impl<T: Stream + Send + 'static> EventStream<T>
impl<T: Stream + Send + 'static> EventStream<T>
sourcepub fn keep_alive(self, duration: Duration) -> Self
pub fn keep_alive(self, duration: Duration) -> Self
Set the keep alive interval.
sourcepub fn to_event(self, f: impl FnMut(T::Item) -> Event + Send + 'static) -> Self
pub fn to_event(self, f: impl FnMut(T::Item) -> Event + Send + 'static) -> Self
Set a function used to convert the message to SSE event.
Examples
use poem::web::sse::Event;
use poem_openapi::{payload::EventStream, types::ToJSON, Object};
#[derive(Debug, Object)]
struct MyEvent {
value: i32,
}
EventStream::new(futures_util::stream::iter(vec![
MyEvent { value: 1 },
MyEvent { value: 2 },
MyEvent { value: 3 },
]))
.to_event(|event| {
let json = event.to_json_string();
Event::message(json).event_type("push")
});Trait Implementations§
source§impl<T: Stream<Item = E> + Send + 'static, E: Type + ToJSON> ApiResponse for EventStream<T>
impl<T: Stream<Item = E> + Send + 'static, E: Type + ToJSON> ApiResponse for EventStream<T>
source§fn register(registry: &mut Registry)
fn register(registry: &mut Registry)
Register the schema contained in this response object to the registry.
source§const BAD_REQUEST_HANDLER: bool = false
const BAD_REQUEST_HANDLER: bool = false
If true, it means that the response object has a custom bad request
handler.
source§fn from_parse_request_error(err: Error) -> Self
fn from_parse_request_error(err: Error) -> Self
Convert
poem::Error to this response object.source§impl<T: Stream<Item = E> + Send + 'static, E: Type + ToJSON + 'static> IntoResponse for EventStream<T>
impl<T: Stream<Item = E> + Send + 'static, E: Type + ToJSON + 'static> IntoResponse for EventStream<T>
source§fn into_response(self) -> Response
fn into_response(self) -> Response
Consume itself and return
Response.source§fn with_header<K, V>(self, key: K, value: V) -> WithHeader<Self>where
K: TryInto<HeaderName>,
V: TryInto<HeaderValue>,
Self: Sized,
fn with_header<K, V>(self, key: K, value: V) -> WithHeader<Self>where
K: TryInto<HeaderName>,
V: TryInto<HeaderValue>,
Self: Sized,
Wrap an
impl IntoResponse to add a header. Read moresource§fn with_content_type<V>(self, content_type: V) -> WithContentType<Self>where
V: TryInto<HeaderValue>,
Self: Sized,
fn with_content_type<V>(self, content_type: V) -> WithContentType<Self>where
V: TryInto<HeaderValue>,
Self: Sized,
Wrap an
impl IntoResponse to with a new content type. Read moresource§fn with_status(self, status: StatusCode) -> WithStatus<Self>where
Self: Sized,
fn with_status(self, status: StatusCode) -> WithStatus<Self>where
Self: Sized,
Wrap an
impl IntoResponse to set a status code. Read moresource§impl<T: Stream<Item = E> + Send + 'static, E: Type + ToJSON> Payload for EventStream<T>
impl<T: Stream<Item = E> + Send + 'static, E: Type + ToJSON> Payload for EventStream<T>
source§const CONTENT_TYPE: &'static str = "text/event-stream"
const CONTENT_TYPE: &'static str = "text/event-stream"
The content type of this payload.
source§fn schema_ref() -> MetaSchemaRef
fn schema_ref() -> MetaSchemaRef
Gets schema reference of this payload.
source§fn register(registry: &mut Registry)
fn register(registry: &mut Registry)
Register the schema contained in this payload to the registry.
source§fn check_content_type(content_type: &str) -> bool
fn check_content_type(content_type: &str) -> bool
Check the content type of incoming request
Auto Trait Implementations§
impl<T> !RefUnwindSafe for EventStream<T>
impl<T> Send for EventStream<T>
impl<T> !Sync for EventStream<T>
impl<T> Unpin for EventStream<T>where
T: Unpin,
impl<T> !UnwindSafe for EventStream<T>
Blanket Implementations§
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoResult<T> for Twhere
T: IntoResponse,
impl<T> IntoResult<T> for Twhere
T: IntoResponse,
source§fn into_result(self) -> Result<T, Error>
fn into_result(self) -> Result<T, Error>
Consumes this value returns a
poem::Result<T>.