-
#187
0e4c6d1
Thanks @tim-smart! - fix filterMap tacit usage
-
#181
eab4bdb
Thanks @gcanti! - Stream: range now includes both endpoints -
#184
29de179
Thanks @gcanti! - rename contramap* functions to mapInput* functions:- Channel
- contramap
- contramapEffect
- contramapError
- contramapErrorEffect
- contramapIn
- contramapInEffect
- contramapContext
- Sink
- contramap
- contramapEffect
- contramapChunks
- contramapChunksEffect
- Stream
- contramapContext
- Channel
-
#185
e02abea
Thanks @tim-smart! - update dependencies -
#177
081ac83
Thanks @tim-smart! - consolidate GroupBy.evaluate & evaluateBuffer
- #178
81e2d51
Thanks @gcanti! - Stream: replace Duration.Duration with Duration.DurationInput in public APIs
- #173
a4855c2
Thanks @tim-smart! - update /io
- #171
e68589c
Thanks @tim-smart! - refactor Scope elimination in signatures
- #169
50d45dd
Thanks @tim-smart! - bump peer deps
-
#167
2293e38
Thanks @tim-smart! - make Stream.prepend a pipeline operator -
#156
b61ab02
Thanks @fubhy! - AlignedStream.mapBoth
signature withEffect.mapBoth
-
#168
b5f64a0
Thanks @tim-smart! - update dependencies
-
#163
3a52300
Thanks @TylorS! - Fix return-type signature of fromPull -
#160
5f713c3
Thanks @tim-smart! - add Emit to asyncScoped signature -
#162
307a35e
Thanks @tim-smart! - add decodeText & encodeText -
#161
39248bd
Thanks @tim-smart! - add Channel/Stream.withSpan
- #154
65d061d
Thanks @tim-smart! - update dependencies
-
#152
6a99bc1
Thanks @tim-smart! - use peer deps for /data and /io -
#151
57f0a12
Thanks @tim-smart! - update build tools
- #147
9390806
Thanks @tim-smart! - update /data and /io
- #146
d5dc5e7
Thanks @tim-smart! - ensure Schedule types don't widen Stream types
- #143
9151acf
Thanks @tim-smart! - fix for non-spec-compliant async iterators
- #141
8dc1c04
Thanks @tim-smart! - update /data and /io
- #139
a67bcc4
Thanks @tim-smart! - reintroduce paritionEither api
- #137
fdf26f2
Thanks @tim-smart! - convert some apis to constants
- #135
b57ca68
Thanks @tim-smart! - ensure tacit api usage doesn't override types
- #133
18d3631
Thanks @tim-smart! - api updates - object options and consolidation
- #131
9704dec
Thanks @tim-smart! - update /io and /data
- #129
c31aa0a
Thanks @tim-smart! - update /io
- #127
be45984
Thanks @tim-smart! - update /io and /data
- #125
5422f79
Thanks @tim-smart! - update /data and /io
-
#123
31eee0b
Thanks @tim-smart! - update /io -
#123
31eee0b
Thanks @tim-smart! - implement Pipeable
-
#115
fe30620
Thanks @IMax153! - close scope in uninterruptible region for Channel.runScoped -
#115
fe30620
Thanks @IMax153! - propagate Cause in Channel.mapOutEffect -
#115
fe30620
Thanks @IMax153! - implement Stream.ensuringWith -
#120
b04b2f6
Thanks @IMax153! - addStream.fromReadableStream
-
#115
fe30620
Thanks @IMax153! - handle stream termination before sink in Stream.tapSink -
#115
fe30620
Thanks @IMax153! - optimize Stream.runIntoQueueElementsScoped -
#115
fe30620
Thanks @IMax153! - handle fractional cycles in Stream.throttleEnforce -
#115
fe30620
Thanks @IMax153! - optimize Stream.groupAdjacentBy -
#115
fe30620
Thanks @IMax153! - catch and forward exceptions in channel read
- #113
e9a0e71
Thanks @tim-smart! - update /io
- #109
a139e7e
Thanks @tim-smart! - fix Stream provideService signatures
- #106
8a9c58d
Thanks @tim-smart! - update dependencies
-
#105
73c31dc
Thanks @tim-smart! - update dependencies -
#103
6f43734
Thanks @tim-smart! - fix catchAll dual signature
- #101
c276050
Thanks @tim-smart! - update /io
- #98
1c27fe4
Thanks @tim-smart! - update dependencies
- #100
8774901
Thanks @tim-smart! - update /io
- #96
ea1e2cf
Thanks @mikearnaldi! - Implement Unify
- #94
745041b
Thanks @mikearnaldi! - Update effect/data and effect/io
- #92
7099133
Thanks @mikearnaldi! - Make Effect a valid Stream and Channel
- #89
c9aa4d1
Thanks @tim-smart! - update /io and /data
-
#87
0ed176a
Thanks @mikearnaldi! - Make Tag a valid Stream -
#87
0ed176a
Thanks @mikearnaldi! - Make Tag a valid Sink -
#87
0ed176a
Thanks @mikearnaldi! - Make Tag a valid Channel
-
#83
72aa089
Thanks @tim-smart! - update dependencies -
#83
72aa089
Thanks @tim-smart! - update for new Tag api
- #81
da67205
Thanks @mikearnaldi! - Add Stream.toChannel
- #79
c68425f
Thanks @mikearnaldi! - Update effect/io and effect/data, in #77
- #75
04fe44b
Thanks @mikearnaldi! - Update effect/io and TS
- #73
fa28bf8
Thanks @mikearnaldi! - Rename repeatForever, improve types of flatMapPar variants
- #73
fa28bf8
Thanks @mikearnaldi! - Add flattenEffectPar variants
- #70
93e6c97
Thanks @tim-smart! - update /io to 0.8.0
- #67
1bc0a91
Thanks @tim-smart! - update /data to 0.4.1
- #68
4ab719a
Thanks @tim-smart! - add Stream.fromAsyncIterable
- #62
67d405c
Thanks @tim-smart! - update /io and /data
- #45
d082e91
Thanks @mikearnaldi! - add tracing to Channel
-
#50
3c2833d
Thanks @tim-smart! - fix subscription ref signatures -
#52
43d8867
Thanks @mikearnaldi! - Propagate finalizer errors in Channel -
#54
012404e
Thanks @IMax153! - fix Stream.merge and Channel.mergeWith
- #48
ccd96a9
Thanks @tim-smart! - update to fp-ts/core 0.2
- #39
f8ea714
Thanks @tim-smart! - implement dual api
-
#46
7a85479
Thanks @IMax153! - propagate defects in Stream.bufferSliding -
#47
e91ae74
Thanks @IMax153! - replace @fp-ts/data with @effect/data -
#42
c33091e
Thanks @tim-smart! - update /data and /io -
#46
65e92b1
Thanks @IMax153! - ensure ChannelExecutor.close is called by the Fiber itself
- #37
5eab61e
Thanks @tim-smart! - update effect/io to 0.1.x
-
#35
4a9db22
Thanks @mikearnaldi! - Update effect/io -
#33
77563e1
Thanks @patroza! - Fix missing _tag in built-in Exceptions
- #31
34db20e
Thanks @mikearnaldi! - Update build scripts
- #29
e2db3a0
Thanks @mikearnaldi! - update effect/io
- #27
6f92a64
Thanks @mikearnaldi! - Update effect/io
-
#23
6ec72d1
Thanks @IMax153! - use _tag over op for Channel helper types -
#23
df474c0
Thanks @IMax153! - use _tag over op for Stream types
-
#21
9658ad9
Thanks @mikearnaldi! - Align naming of singleton to of
- #15
5bdbeb2
Thanks @mikearnaldi! - Add Stream.onEnd and fix mistaken mutations category
- #12
91d483b
Thanks @mikearnaldi! - Update effect/io, detach from stm