diff --git a/benches/deserialization_benchmark.rs b/benches/deserialization_benchmark.rs index af65bea2..3428c2d6 100644 --- a/benches/deserialization_benchmark.rs +++ b/benches/deserialization_benchmark.rs @@ -3,13 +3,13 @@ use criterion::{criterion_group, criterion_main}; use criterion::{BatchSize, Criterion}; use std::io::Cursor; -use bromine::event::Event; +use bromine::event::{Event, EventType}; use tokio::runtime::Runtime; pub const EVENT_NAME: &str = "bench_event"; fn create_event_bytes_reader(data_size: usize) -> Cursor> { - let bytes = Event::new(EVENT_NAME.to_string(), vec![0u8; data_size], None) + let bytes = Event::initiator(None, EVENT_NAME.to_string(), vec![0u8; data_size]) .into_bytes() .unwrap(); Cursor::new(bytes) diff --git a/benches/serialization_benchmark.rs b/benches/serialization_benchmark.rs index 8f9f6e98..2d25643b 100644 --- a/benches/serialization_benchmark.rs +++ b/benches/serialization_benchmark.rs @@ -6,7 +6,7 @@ use criterion::{ pub const EVENT_NAME: &str = "bench_event"; fn create_event(data_size: usize) -> Event { - Event::new(EVENT_NAME.to_string(), vec![0u8; data_size], None) + Event::initiator(None, EVENT_NAME.to_string(), vec![0u8; data_size]) } fn event_serialization(c: &mut Criterion) { diff --git a/src/events/event.rs b/src/events/event.rs index f94df91c..c6e33ddc 100644 --- a/src/events/event.rs +++ b/src/events/event.rs @@ -41,31 +41,21 @@ impl Event { /// Creates a new event that acts as an initiator for further response events #[tracing::instrument(level = "trace", skip(data))] #[inline] - pub(crate) fn initiator(namespace: Option, name: String, data: Vec) -> Self { + pub fn initiator(namespace: Option, name: String, data: Vec) -> Self { Self::new(namespace, name, data, None, EventType::Initiator) } /// Creates a new event that is a response to a previous event #[tracing::instrument(level = "trace", skip(data))] #[inline] - pub(crate) fn response( - namespace: Option, - name: String, - data: Vec, - ref_id: u64, - ) -> Self { + pub fn response(namespace: Option, name: String, data: Vec, ref_id: u64) -> Self { Self::new(namespace, name, data, Some(ref_id), EventType::Response) } /// Creates a new error event as a response to a previous event #[tracing::instrument(level = "trace", skip(data))] #[inline] - pub(crate) fn error( - namespace: Option, - name: String, - data: Vec, - ref_id: u64, - ) -> Self { + pub fn error(namespace: Option, name: String, data: Vec, ref_id: u64) -> Self { Self::new(namespace, name, data, Some(ref_id), EventType::Error) } @@ -73,7 +63,7 @@ impl Event { /// and might contain a final response payload #[tracing::instrument(level = "trace", skip(data))] #[inline] - pub(crate) fn end(namespace: Option, name: String, data: Vec, ref_id: u64) -> Self { + pub fn end(namespace: Option, name: String, data: Vec, ref_id: u64) -> Self { Self::new(namespace, name, data, Some(ref_id), EventType::Response) }