38 Commits

Author	SHA1	Message	Date
Orion Kindel	dc7a2d3387	feat: Pipe.Util.buffered	2024-07-08 12:40:25 -05:00
Orion Kindel	4a9dbf0a3c	fix: relax pipeAsync constraints	2024-06-25 14:20:25 -05:00
Orion Kindel	dc1ba322a9	fix: asyncpipe is mfunctor	2024-06-23 20:49:17 -05:00
Orion Kindel	860ace3990	feat: AsyncPipe really should be a monad	2024-06-23 18:33:45 -05:00
Orion Kindel	2e0be4ac62	fix: loop bug	2024-06-22 19:33:45 -05:00
Orion Kindel	08bd9a817a	fix: asyncpipe is profunctor	2024-06-22 19:12:31 -05:00
Orion Kindel	5b3eda707e	feat!: add AsyncPipe abstraction, significantly improve throughput of Transform streams	2024-06-22 18:42:22 -05:00
Orion Kindel	d76f55e267	fix: introduced transform bug	2024-06-21 13:21:19 -05:00
Orion Kindel	a8702f4849	fix: finish may not emit until all chunks are read	2024-06-20 15:40:17 -05:00
Orion Kindel	4242330bef	fix: write readme, clarify API	2024-05-15 13:30:08 -05:00
Orion Kindel	657af14bb6	fix: await finished before exiting	2024-05-14 14:07:20 -05:00
Orion Kindel	33d42034fc	fix: continue to read after readableEnded	2024-05-14 13:51:57 -05:00
Orion Kindel	c8822aeffe	fix: I WAS INCORRECT HHEHE	2024-05-14 13:44:33 -05:00
Orion Kindel	7076b13df4	fix: catch incorrect stream implementations	2024-05-14 13:42:39 -05:00
Orion Kindel	fd53b6520f	feat: Collect.toBuffer	2024-05-14 13:12:41 -05:00
Orion Kindel	0ef7240d61	wip: explore removing delays(10)	2024-05-14 12:44:31 -05:00
Orion Kindel	de22f44f86	wip: explore removing delays(9)	2024-05-14 12:43:38 -05:00
Orion Kindel	f9c0e20777	wip: explore removing delays(8)	2024-05-14 11:08:46 -05:00
Orion Kindel	edc7d40dbc	wip: explore removing delays(7)	2024-05-14 11:04:50 -05:00
Orion Kindel	ba8d90038d	wip: explore removing delays(6)	2024-05-14 10:55:14 -05:00
Orion Kindel	dfdca9f5e9	wip: explore removing delays(5)	2024-05-14 10:39:06 -05:00
Orion Kindel	67ae171532	wip: explore removing delays(4)	2024-05-13 21:18:27 -05:00
Orion Kindel	a347c05062	wip: explore removing delays(3)	2024-05-13 21:17:28 -05:00
Orion Kindel	f9446c97a0	wip: explore removing delays(2)	2024-05-13 21:15:45 -05:00
Orion Kindel	d3b8d1792d	wip: explore removing delays	2024-05-13 21:06:41 -05:00
Orion Kindel	e05c74f42f	fix: minor fixes	2024-05-13 15:04:34 -05:00
Orion Kindel	820351f800	fix: more yields	2024-05-13 14:42:23 -05:00
Orion Kindel	b7bead090e	fix: transform should read more than just 1 chunk after writing	2024-05-13 14:35:44 -05:00
Orion Kindel	1a5ca66e83	fix: Pipes.Node.FS.read'	2024-05-13 13:27:18 -05:00
Orion Kindel	a5c535fb1e	feat: Pipes.Construct	2024-05-13 11:21:06 -05:00
Orion Kindel	407491f055	fix: generalize all Affs to MonadAffs	2024-05-11 22:08:27 -05:00
Orion Kindel	eb01962553	feat: fix inEOS, add uniqHash + invoke	2024-05-11 22:01:06 -05:00
Orion Kindel	634e52fe39	fix: more Pipes.Collect utils, stack-safety	2024-05-11 18:01:43 -05:00
Orion Kindel	76958b63ef	feat: Pipes.Util.chunked	2024-05-10 18:30:27 -05:00
Orion Kindel	f373334f77	feat: Pipes.Collect	2024-05-10 18:15:58 -05:00
Orion Kindel	3c8e497fa2	fix: explicit tailRecM	2024-05-10 18:03:34 -05:00
Orion Kindel	805f3b8887	feat: Pipes.Node.FS, Pipes.Node.Buffer, etc.	2024-05-10 15:04:18 -05:00
Orion Kindel	e0cf34f420	fix: init	2024-05-09 17:21:15 -05:00