Function dropUntilEffect

packages/effect/src/internal/sink.ts:577–579

(
  predicate: (input: In) => Effect.Effect<boolean, E, R>
)

/** @internal */
export const dropUntilEffect = <In, E, R>(
  predicate: (input: In) => Effect.Effect<boolean, E, R>
): Sink.Sink<unknown, In, In, E, R> => suspend(() => new SinkImpl(dropUntilEffectReader(predicate)))

/** @internal */
const dropUntilEffectReader = <In, R, E>(