Understanding Fiber Lifecycle and Blocking Operations

I have question about blocking apis, I'm using following code snippet:

yield* Effect.promise(() => consumer.run({ eachBatch })).pipe(
  Effect.tap(() => Effect.logInfo("Consumer started")),
);

yield* Effect.promise(() => consumer.run({ eachBatch })).pipe(
  Effect.tap(() => Effect.logInfo("Consumer started")),
);

where

run

run

is blocking operation, what I expect is

Consumer started

Consumer started

log would not be reached, however I see it is printed.
Apparently, I'm a bit confused about fiber lifecycle, could someone explain why it is printed and should I chain it with

never

never

effect to avoid this?

yield* Effect.promise(() => consumer.run({ eachBatch })).pipe(
  Effect.andThen(() => Effect.never),
  Effect.tap(() => Effect.logInfo("Consumer started")),
);

yield* Effect.promise(() => consumer.run({ eachBatch })).pipe(
  Effect.andThen(() => Effect.never),
  Effect.tap(() => Effect.logInfo("Consumer started")),
);

Effect Community•2y ago

Victor Korzunin

Understanding Fiber Lifecycle and Blocking Operations

I have question about blocking apis, I'm using following code snippet:

yield* Effect.promise(() => consumer.run({ eachBatch })).pipe(
  Effect.tap(() => Effect.logInfo("Consumer started")),
);

yield* Effect.promise(() => consumer.run({ eachBatch })).pipe(
  Effect.tap(() => Effect.logInfo("Consumer started")),
);

where

run

run

is blocking operation, what I expect is

Consumer started

Consumer started

log would not be reached, however I see it is printed.
Apparently, I'm a bit confused about fiber lifecycle, could someone explain why it is printed and should I chain it with

never

never

effect to avoid this?

yield* Effect.promise(() => consumer.run({ eachBatch })).pipe(
  Effect.andThen(() => Effect.never),
  Effect.tap(() => Effect.logInfo("Consumer started")),
);

yield* Effect.promise(() => consumer.run({ eachBatch })).pipe(
  Effect.andThen(() => Effect.never),
  Effect.tap(() => Effect.logInfo("Consumer started")),
);

Understanding Fiber Lifecycle and Blocking Operations

Similar Threads

Understanding Fiber Lifecycle and Blocking Operations

Similar Threads

Similar Threads

Similar Threads