pub fn trace(
info: Arc<ExecutorInfo>,
actor_ctx: ActorContextRef,
input: impl MessageStream,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>Expand description
Streams wrapped by trace will be traced with tracing spans and reported to opentelemetry.