Managing Log Annotations in Different Parts of a Stream

How to have different logs annotations in different parts of the same stream?

For example

Stream.merge(
  Stream.fromSchedule(Schedule.spaced('1 second')).pipe(
    Stream.tap((x) => Effect.log(x)),
  ),
  Stream.fromSchedule(Schedule.spaced('2 second')).pipe(
    Stream.tap((x) => Effect.log(x)),
  ),
)

Stream.merge(
  Stream.fromSchedule(Schedule.spaced('1 second')).pipe(
    Stream.tap((x) => Effect.log(x)),
  ),
  Stream.fromSchedule(Schedule.spaced('2 second')).pipe(
    Stream.tap((x) => Effect.log(x)),
  ),
)

Stream.merge(
  Stream.fromSchedule(Schedule.spaced('1 second')).pipe(
    Stream.tap((x) => Effect.log(x)),
  ),
  Stream.fromSchedule(Schedule.spaced('2 second')).pipe(
    Stream.tap((x) => Effect.log(x)),
  ),
)

Stream.merge(
  Stream.fromSchedule(Schedule.spaced('1 second')).pipe(
    Stream.tap((x) => Effect.log(x)),
  ),
  Stream.fromSchedule(Schedule.spaced('2 second')).pipe(
    Stream.tap((x) => Effect.log(x)),
  ),
)

I understand, that i can apply annotateLogs directly to the

Effect.log

Effect.log

Effect.log

Effect.log in this case, but i need to provide the annotation for the whole stream pipeline

No replies yetBe the first to reply to this messageJoin

Managing Log Annotations in Different Parts of a Stream

Similar Threads

Similar Threads

Similar Threads