Function schema_check

pub fn schema_check(
    info: Arc<ExecutorInfo>,
    input: impl MessageStream,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>

Streams wrapped by schema_check will check the passing stream chunk against the expected schema.