Skip to content

Commit

Permalink
✅ Fix failing tests
Browse files Browse the repository at this point in the history
  • Loading branch information
rster2002 committed May 14, 2024
1 parent fead9f9 commit 9b44fe7
Show file tree
Hide file tree
Showing 5 changed files with 8 additions and 5 deletions.
2 changes: 2 additions & 0 deletions ed-journals/src/modules/blockers/mod.rs
Original file line number Diff line number Diff line change
@@ -1,2 +1,4 @@
pub mod sync_blocker;

#[cfg(feature = "asynchronous")]
pub mod async_blocker;
2 changes: 2 additions & 0 deletions ed-journals/src/modules/journal/mod.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,6 @@
pub mod blocking;

#[cfg(feature = "asynchronous")]
pub mod asynchronous;

mod journal_event;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ use crate::modules::blockers::sync_blocker::SyncBlocker;
///
/// let path = PathBuf::from("somePath");
///
/// let live_dir_reader = LiveLogDirReader::create(path)
/// let live_dir_reader = LiveLogDirReader::open(path)
/// .unwrap();
///
/// // At first this will read all existing lines from the journal logs, after which it will block
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ use crate::modules::logs::blocking::{LogFileReader, LogFileReaderError};
///
/// let path = PathBuf::from("somePath");
///
/// let live_reader = LiveLogFileReader::new(path)
/// let live_reader = LiveLogFileReader::open(path)
/// .unwrap();
///
/// // This will block the current thread until there are new entries.
Expand Down
5 changes: 2 additions & 3 deletions ed-journals/src/modules/logs/blocking/log_file_reader.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,15 +23,14 @@ use crate::logs::content::LogEvent;
/// .unwrap()
/// .join("test-journals");
///
/// let journal_dir = LogDir::new(dir_path)
/// .unwrap();
/// let journal_dir = LogDir::new(dir_path);
///
/// let logs = journal_dir.journal_logs_oldest_first().unwrap();
/// assert!(!logs.is_empty());
///
/// for journal_file in logs {
/// // Create a reader
/// let reader = journal_file.create_reader().unwrap();
/// let reader = journal_file.create_blocking_reader().unwrap();
///
/// for entry in reader {
/// let Ok(log) = entry else {
Expand Down

0 comments on commit 9b44fe7

Please sign in to comment.