MCPcopy Create free account
hub / github.com/comnik/declarative-dataflow / test_single

Method test_single

src/server/mod.rs:527–545  ·  view source on GitHub ↗

Helper for registering, publishing, and indicating interest in a single, named query. Used for testing.

(
        &mut self,
        scope: &mut S,
        rule: Rule,
    )

Source from the content-addressed store, hash-verified

525 /// Helper for registering, publishing, and indicating interest in
526 /// a single, named query. Used for testing.
527 pub fn test_single<S: Scope<Timestamp = T>>(
528 &mut self,
529 scope: &mut S,
530 rule: Rule,
531 ) -> Collection<S, Vec<Value>, isize> {
532 let interest_name = rule.name.clone();
533 let publish_name = rule.name.clone();
534
535 self.register(Register {
536 rules: vec![rule],
537 publish: vec![publish_name],
538 })
539 .unwrap();
540
541 match self.interest(&interest_name, scope) {
542 Err(error) => panic!("{:?}", error),
543 Ok(relation) => relation.probe_with(&mut self.probe),
544 }
545 }
546}
547
548impl<Token> Server<Duration, Token>

Callers 10

mainFunction · 0.80
run_casesFunction · 0.80
run_casesFunction · 0.80
run_casesFunction · 0.80
runMethod · 0.80
match_ea_after_inputFunction · 0.80
join_after_inputFunction · 0.80
run_transform_casesFunction · 0.80
run_hector_casesFunction · 0.80
run_casesFunction · 0.80

Calls 2

registerMethod · 0.80
interestMethod · 0.80

Tested by

no test coverage detected