We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1fa4308 commit d1b1f30Copy full SHA for d1b1f30
src/parseable/mod.rs
@@ -211,6 +211,8 @@ impl Parseable {
211
}
212
213
/// Checks for the stream in memory, or loads it from storage when in distributed mode
214
+ /// return true if stream exists in memory or loaded from storage
215
+ /// return false if stream doesn't exist in memory and not loaded from storage
216
pub async fn check_or_load_stream(&self, stream_name: &str) -> bool {
217
if self.streams.contains(stream_name) {
218
return true;
0 commit comments