( f: (scope: Scope.Scope) => Effect.Effect<A, E, R> )
| 6191 | |
| 6192 | /** @internal */ |
| 6193 | export const scopedWith = <A, E, R>( |
| 6194 | f: (scope: Scope.Scope) => Effect.Effect<A, E, R> |
| 6195 | ): Stream.Stream<A, E, R> => |
| 6196 | new StreamImpl(channel.scopedWith((scope) => |
| 6197 | f(scope).pipe( |
| 6198 | Effect.map(Chunk.of) |
| 6199 | ) |
| 6200 | )) |
| 6201 | |
| 6202 | /** @internal */ |
| 6203 | export const some = <A, E, R>(self: Stream.Stream<Option.Option<A>, E, R>): Stream.Stream<A, Option.Option<E>, R> => |
no test coverage detected
searching dependent graphs…