(hadError: boolean)
| 144 | ) |
| 145 | } |
| 146 | function onClose(hadError: boolean) { |
| 147 | Deferred.unsafeDone( |
| 148 | fiberSet.deferred, |
| 149 | Effect.fail( |
| 150 | new Socket.SocketCloseError({ |
| 151 | reason: "Close", |
| 152 | code: hadError ? 1006 : 1000 |
| 153 | }) |
| 154 | ) |
| 155 | ) |
| 156 | } |
| 157 | })).pipe( |
| 158 | Effect.mapInputContext((input: Context.Context<R>) => Context.merge(openContext, input)), |
| 159 | Effect.ensuring(Effect.sync(() => { |
nothing calls this directly
no test coverage detected