Ranjeet Kumar Ranjan
|
bf966be08d
|
Remove internal core-modules
|
2022-10-20 18:22:34 +05:30 |
|
Ranjeet Kumar Ranjan
|
d1022f0491
|
Re-export exposed modules in streamly-core from streamly
|
2022-10-20 14:53:57 +05:30 |
|
Adithya Kumar
|
dbc54c1e82
|
Expose Fold.the and Fold.uniq
|
2022-10-19 19:53:50 +05:30 |
|
Adithya Kumar
|
f1e265cec2
|
Move concurrent combinators to the newer stream modules
|
2022-10-19 19:53:37 +05:30 |
|
Adithya Kumar
|
74b18bf872
|
Implement scanlMAfter'
|
2022-10-19 19:53:37 +05:30 |
|
Adithya Kumar
|
56569bcb18
|
Change the Unboxed type class alias
|
2022-10-19 18:44:36 +05:30 |
|
Ranjeet Kumar Ranjan
|
6690046f41
|
Remove Streamly.Data.Unbox module
|
2022-10-19 18:44:36 +05:30 |
|
Harendra Kumar
|
879c24e774
|
Implement a concurrent fold channel
|
2022-10-18 23:00:39 +05:30 |
|
Ranjeet Ranjan
|
0a5dbe9da5
|
Add repeatM to Streamly.Data.Stream module (#1957)
|
2022-10-18 22:58:09 +05:30 |
|
Ranjeet Ranjan
|
e5f17d0627
|
Add Data.Stream.Zip.Concurrent module (#1954)
|
2022-10-18 22:54:57 +05:30 |
|
Ranjeet Ranjan
|
f20360b86e
|
Rename Async benchmark modules (#1968)
|
2022-10-18 22:53:30 +05:30 |
|
Harendra Kumar
|
1f376cfd9b
|
Rename some parsers (#1976)
Rename:
element -> oneEq
except -> oneNotEq
eqBy -> listEqBy
matchBy -> eqBy
Change the signature of eqBy to return the list.
|
2022-10-18 16:40:08 +05:30 |
|
Ranjeet Ranjan
|
66036810f9
|
Add zipWith to Data.Stream.Concurrent (#1953)
|
2022-10-18 16:05:29 +05:30 |
|
Harendra Kumar
|
00265b40d2
|
Rename Stream.Async benchmark to Stream.Concurrent
|
2022-10-17 16:32:47 +05:30 |
|
Harendra Kumar
|
162fc171df
|
Separate interleaved benchmarks in another module
|
2022-10-17 16:32:47 +05:30 |
|
Harendra Kumar
|
f7415e9b44
|
Use list based concat functions in place of binary ops
|
2022-10-17 16:31:34 +05:30 |
|
Harendra Kumar
|
0cd6d6248a
|
Structure the docs of Stream.Concurrent
|
2022-10-17 16:31:34 +05:30 |
|
Adithya Kumar
|
0aacf72d18
|
Remove duplicate combinators in internal Stream.Zip
|
2022-10-17 10:54:25 +05:30 |
|
Harendra Kumar
|
362ceb1e39
|
Rename eagerEval to eager and inspectMode to inspect
|
2022-10-16 20:18:16 +05:30 |
|
Harendra Kumar
|
c60b70472d
|
Use conventional style signature for withChannel
|
2022-10-16 20:17:29 +05:30 |
|
Harendra Kumar
|
ee2fd6976d
|
Cleanly separate the Channel and stream modules
|
2022-10-16 20:17:29 +05:30 |
|
Harendra Kumar
|
1af6776f74
|
Fix performance regression - use MonadAsync constraint
|
2022-10-16 20:02:37 +05:30 |
|
Harendra Kumar
|
bfec356951
|
Implement "interleaved" config option
For concurrent streams.
|
2022-10-16 20:02:37 +05:30 |
|
Harendra Kumar
|
b7e890767d
|
Update comments in export list of Concurrent
|
2022-10-16 20:02:37 +05:30 |
|
Ranjeet Ranjan
|
8f602ac644
|
Expose parseMany (#1956)
|
2022-10-15 17:05:22 +05:30 |
|
Ranjeet Ranjan
|
2e5e314dc1
|
Add bounds to monad-control in streamly.cabal (#1955)
|
2022-10-15 17:04:22 +05:30 |
|
Harendra Kumar
|
cef0c5935b
|
Reset doorbell flag after wakeup in sendWorkerWait
|
2022-10-15 16:40:17 +05:30 |
|
Harendra Kumar
|
36953a1290
|
Fix TypeOperator and strictness warnings for GHC 9.4
|
2022-10-13 20:22:01 +05:30 |
|
Ranjeet Ranjan
|
73b15ccbde
|
Use GHC-9.4.2 for inspection tests (#1884)
|
2022-10-13 19:16:09 +05:30 |
|
Ranjeet Ranjan
|
36410d9ff6
|
Expose Streamly.Data.Stream.Zip from streamly-core package (#1945)
|
2022-10-13 19:10:46 +05:30 |
|
Ranjeet Ranjan
|
8d8e5a0c30
|
Implement timestamp* and timeIndex* operations (#1944)
|
2022-10-13 15:46:40 +05:30 |
|
Harendra Kumar
|
bc60c1ab88
|
Move IsStream modules to deprecated section
All these modules are to be deprecated after ensuring that all equivalent
functionality is available in other modules.
|
2022-10-13 01:39:24 +05:30 |
|
Harendra Kumar
|
d3ec4917d9
|
Revert "Split Serial module into Serial and WSerial"
This reverts commit 5ddfb45764.
|
2022-10-13 01:27:53 +05:30 |
|
Harendra Kumar
|
98da856b53
|
Revert "Move Data.Stream.Async to Data.Stream.IsStream.Async"
This reverts commit 30c98dc65f.
|
2022-10-13 00:32:45 +05:30 |
|
Harendra Kumar
|
de8b77b092
|
Revert "Move the Parallel module under IsStream"
This reverts commit e718389b2c.
|
2022-10-13 00:30:52 +05:30 |
|
Harendra Kumar
|
2a2899f259
|
Keep only two sdist builds
streamly sdist builds are likely to fail when changes are made to
streamly-core package.
|
2022-10-12 22:33:58 +05:30 |
|
Harendra Kumar
|
ad254d8513
|
Update docs, add notes about mono repo
|
2022-10-12 22:33:58 +05:30 |
|
Ranjeet Kumar Ranjan
|
8a76b6730a
|
Remove streamly-core from extra-source files
|
2022-10-12 22:33:58 +05:30 |
|
Ranjeet Ranjan
|
2c84b4ddc7
|
Expose concurrent operations via Streamly.Data.Stream.Concurrent (#1930)
|
2022-10-12 22:23:05 +05:30 |
|
Ranjeet Ranjan
|
5a42524161
|
Rename Async benchmarks to Concurrent benchmarks (#1929)
|
2022-10-12 15:38:14 +05:30 |
|
Ranjeet Ranjan
|
7ac9ab7d5b
|
Rename Data.Stream.Async to Data.Stream.Concurrent (#1926)
|
2022-10-11 16:41:45 +05:30 |
|
Harendra Kumar
|
edc9d3ad8f
|
Add the ordered option in Async tests
|
2022-10-11 00:23:09 +05:30 |
|
Harendra Kumar
|
8e4f8b2d56
|
Implement appendWithK for ordered using concatMap
Ahead stream implementation expects only one element in the work queue.
|
2022-10-11 00:23:09 +05:30 |
|
Harendra Kumar
|
ae37ca3f44
|
Add benchmarks for ordered concurrent streams (ahead)
|
2022-10-11 00:23:09 +05:30 |
|
Harendra Kumar
|
8480c9ee25
|
Add an 'ahead' operation for ordered append
|
2022-10-11 00:23:09 +05:30 |
|
Harendra Kumar
|
b5d26415ed
|
Implement an "ordered" option in concurrent streams
This is the equivalent of the Ahead style streams.
|
2022-10-11 00:23:09 +05:30 |
|
Harendra Kumar
|
6c4b36105d
|
Stop the channel when a particular stream ends
|
2022-10-10 18:21:51 +05:30 |
|
Harendra Kumar
|
18e656ff95
|
Add eagerEval option in Async tests
|
2022-10-10 18:20:44 +05:30 |
|
Harendra Kumar
|
0945bc327b
|
Add benchmarks for eagerEval option
|
2022-10-10 18:20:44 +05:30 |
|
Harendra Kumar
|
4eaeb10c97
|
Use static argument transformation for better perf
It seems to make signifcant difference in CPU cycles.
|
2022-10-10 18:20:44 +05:30 |
|