()
| 139 | } |
| 140 | |
| 141 | get raw(): Effect.Effect<unknown, Error.SqlError> { |
| 142 | return this.withConnection( |
| 143 | "executeRaw", |
| 144 | (connection, sql, params) => connection.executeRaw(sql, params), |
| 145 | true |
| 146 | ) |
| 147 | } |
| 148 | |
| 149 | get stream(): Stream.Stream<A, Error.SqlError> { |
| 150 | return Stream.unwrapScoped(Effect.flatMap( |
no test coverage detected