Ranjeet Kumar Ranjan
73c8d926fd
Fix up
2022-10-17 18:03:39 +05:30
Ranjeet Kumar Ranjan
136158dd87
Fix merge
2022-10-17 17:08:18 +05:30
Ranjeet Kumar Ranjan
a224845eb0
Add zipWith to Data.Stream.Concurrent
2022-10-17 16:59:20 +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
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
Harendra Kumar
cef0c5935b
Reset doorbell flag after wakeup in sendWorkerWait
2022-10-15 16:40:17 +05:30
Ranjeet Ranjan
73b15ccbde
Use GHC-9.4.2 for inspection tests ( #1884 )
2022-10-13 19:16:09 +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
Ranjeet Ranjan
2c84b4ddc7
Expose concurrent operations via Streamly.Data.Stream.Concurrent ( #1930 )
2022-10-12 22:23:05 +05:30
Ranjeet Ranjan
7ac9ab7d5b
Rename Data.Stream.Async to Data.Stream.Concurrent ( #1926 )
2022-10-11 16:41:45 +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
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
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
Harendra Kumar
13563a0032
Use eager dispatch when dispatching from consumer loop
2022-10-10 18:20:44 +05:30
Harendra Kumar
07b25394c4
Implement an eagerEval option
...
When this option is used dispatching of new workers cannot be blocked by
the consumer thread processing. Also, we dispatch as soon as possible
unless the maxThreads or maxBuffer limit is breached.
2022-10-10 18:20:44 +05:30
Harendra Kumar
a6108c9065
Refactor dispatchWorker, prepare for eagerEval impl
2022-10-10 18:20:44 +05:30
Harendra Kumar
34a3a294be
Add two queues (outer and inner) in Async streams
...
To avoid the possibility of out of order execution of the outer loop
blowing up the queue size to unbounded size.
2022-10-10 16:36:21 +05:30
Harendra Kumar
a3203ff9b1
Add inspectMode and applyWith to the Async module
2022-10-10 16:29:28 +05:30
Harendra Kumar
1a46cd5459
Add newlines in the Channel dump function
2022-10-10 16:29:28 +05:30
Harendra Kumar
2f6f9a2d4e
Edit documentation and comments in concurrent modules
...
* Fix typo in StreamK
* Fix typo in the Dispatcher module
* Edit comments in Interleave module
* Clarify the documentation of "rate" (Async)
2022-10-10 16:29:28 +05:30
Harendra Kumar
770887d62f
Move concatMapDivK to common channel module
2022-10-10 16:29:28 +05:30
Adithya Kumar
e061109f76
Add Streamly.Data.Stream.Concurrent
2022-10-07 11:39:00 +05:30
Adithya Kumar
ba01fcd958
Rename and move unboxed array APIs
...
Added Unboxed.newUnpinnedBytes and Mut.Type.newUnpinned
Array.Unboxed.Mut.Type.nilArrayContents -> Unboxed.nil
Array.Unboxed.Mut.Type.newAlignedArrayContents -> Unboxed.newAlignedPinnedBytes
Mut.Type:
newArray -> newPinned
newArrayAligned -> newAlignedPinned
Unboxed:
newUnpinnedArrayContents -> newUnpinnedBytes
2022-10-07 11:37:50 +05:30
Adithya Kumar
6e021ceb18
Change the signature of replicateM
2022-10-06 15:17:46 +05:30
Ranjeet Ranjan
05eb489fd3
Rename head to one ( #1887 )
2022-10-04 17:00:29 +05:30
Ranjeet Ranjan
4ab5ba2ce9
Rename *.Foreign to *.Unboxed modules in streamly-core ( #1877 )
2022-10-03 18:24:31 +05:30
Ranjeet Ranjan
249efda55e
Move Streamly.Data.Array module to streamly-core ( #1881 )
2022-10-01 00:33:41 +05:30
Ranjeet Kumar Ranjan
61af9fc739
Move Streamly.Internal.Data.Binary.Decode to streamly-core
2022-10-01 00:30:25 +05:30
Adithya Kumar
d84f82d973
Remove redundant GHC 8.8 CPP conditional
2022-09-30 15:28:24 +05:30
Ranjeet Kumar Ranjan
88334a8190
Move Console.Stdio to streamly-core
...
And some formatting changes.
2022-09-29 22:50:34 +05:30
Ranjeet Kumar Ranjan
f609af1d01
Move Streamly.FileSystem.Handle to streamly-core
...
And some formatting changes.
2022-09-29 15:28:35 +05:30
Harendra Kumar
e718389b2c
Move the Parallel module under IsStream
2022-09-29 02:25:18 +05:30
Ranjeet Ranjan
05ff41e946
Make formattting changes in network modules ( #1851 )
2022-09-29 02:15:26 +05:30
Ranjeet Ranjan
70e4a57416
Remove IsStream import from FileSystem.Event.* modules ( #1849 )
2022-09-29 02:09:54 +05:30
Ranjeet Kumar Ranjan
182edfd74f
Move Streamly.Unicode to streamly-core
2022-09-28 19:27:29 +05:30
Harendra Kumar
51fb1b8c29
Move common parts of Channel out of Async module
2022-09-28 18:01:45 +05:30
Adithya Kumar
09ed99de1f
Remove support for GHC 8.4.*
2022-09-28 17:50:58 +05:30
Adithya Kumar
a39a95824f
Move IOVec and dependent modules under !ghcjs && dev flag
2022-09-28 15:09:06 +05:30
Ranjeet Ranjan
aef0a2e793
Move Array.Stream.Foreign to streamly-core ( #1863 )
2022-09-27 13:38:12 +05:30
Ranjeet Ranjan
a519c85bad
Remove IsStream imports from FileSystem.File module ( #1850 )
2022-09-26 16:54:35 +05:30
