(a: A, leftovers?: NonEmptyReadonlyArray<L> | undefined)
| 512 | * @since 2.0.0 |
| 513 | */ |
| 514 | export const fromQueue = <A>( |
| 515 | queue: Queue.Queue<A, Cause.Done> |
| 516 | ): Sink<void, A> => |
| 517 | fromTransform((upstream) => |
| 518 | upstream.pipe( |
no test coverage detected
searching dependent graphs…