Skip to content

Commit

Permalink
Fixed incorrect feature flag usage for the unstable-runtime-subscribe…
Browse files Browse the repository at this point in the history
… feature

Signed-off-by: Dan Spencer <[email protected]>
  • Loading branch information
danrspencer committed Feb 18, 2023
1 parent a320b19 commit e152543
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions kube-runtime/src/utils/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,13 +3,13 @@
mod backoff_reset_timer;
mod event_flatten;
mod stream_backoff;
#[cfg(feature = "unstable_runtime_subscribe")] mod stream_subscribe;
#[cfg(feature = "unstable-runtime-subscribe")] mod stream_subscribe;
mod watch_ext;

pub use backoff_reset_timer::ResetTimerBackoff;
pub use event_flatten::EventFlatten;
pub use stream_backoff::StreamBackoff;
#[cfg(feature = "unstable_runtime_subscribe")]
#[cfg(feature = "unstable-runtime-subscribe")]
pub use stream_subscribe::StreamSubscribe;
pub use watch_ext::WatchStreamExt;

Expand Down
4 changes: 2 additions & 2 deletions kube-runtime/src/utils/watch_ext.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
#[cfg(feature = "unstable_runtime_subscribe")]
#[cfg(feature = "unstable-runtime-subscribe")]
use crate::utils::stream_subscribe::StreamSubscribe;
use crate::{
utils::{event_flatten::EventFlatten, stream_backoff::StreamBackoff},
Expand Down Expand Up @@ -93,7 +93,7 @@ pub trait WatchStreamExt: Stream {
/// (stream_subscribe, explain_stream)
/// }
/// ```
#[cfg(feature = "unstable_runtime_subscribe")]
#[cfg(feature = "unstable-runtime-subscribe")]
fn stream_subscribe<K>(self) -> StreamSubscribe<Self>
where
Self: Stream<Item = Result<watcher::Event<K>, watcher::Error>> + Send + Sized + 'static,
Expand Down

0 comments on commit e152543

Please sign in to comment.