Commit graph

27486 commits

Author SHA1 Message Date
He-Pin(kerr)
d313eef0a9
chore: Add collect operator test for stream javadsl. (#963) 2024-01-16 10:13:29 +08:00
PJ Fanning
7c82c2a1c4
fix up javadoc on Creator trait (#961) 2024-01-16 00:56:25 +08:00
He-Pin(kerr)
87609395a6
chore: Deprecate JAPI. (#949) 2024-01-15 19:34:25 +08:00
PJ Fanning
dc034749b3
use sbt-pekko-build (#826)
* try sbt-pekko-build

* Use latest sbt-pekko-build 0.3.0

* remove temp resolver

---------

Co-authored-by: Matthew de Detrich <matthew.dedetrich@aiven.io>
2024-01-15 10:44:49 +01:00
He-Pin(kerr)
df302b8ee6
feat: Add create method to PFBuilder. (#947) 2024-01-15 17:37:14 +08:00
kerr
cf70478201
feat: Add dimap operator to Flow. (#942) 2024-01-15 15:01:34 +08:00
kerr
057fe066e8
chore: Fix compiling error in AsSubscriber.java and FromPublisher.java (#953) 2024-01-15 11:12:25 +08:00
A. Halim
c411fa528a Remove repeated word 2024-01-15 11:10:30 +08:00
He-Pin
3a1b811277 chore: Fix scaladoc link in contramap.md 2024-01-15 09:47:20 +08:00
PJ Fanning
8c688dad2e
use more of StandardCharsets (#952)
* use more of StandardCharsets

* scalafmt
2024-01-14 23:50:50 +01:00
He-Pin
485639ef82 chore: Ignore two pb files from java formatter. 2024-01-14 23:29:40 +08:00
He-Pin
43bab55616 chore: Add @since 1.1.0 to contramap operator. 2024-01-14 23:09:49 +08:00
He-Pin
447728f3c0 feat: Add flatten operator. 2024-01-14 20:24:06 +08:00
Laglangyue
6872f9c8b7
Fix some non-standard comments (#939)
* Fix some non-standard comments

* revert

---------

Co-authored-by: Jiafu Tang <jiafu.tang@qq.com>
2024-01-14 12:47:51 +01:00
He-Pin
269748d674 chore: Add foreach to index.md 2024-01-14 19:09:18 +08:00
scala-steward-asf[bot]
aebe6cd4bc
Update jul-to-slf4j, log4j-over-slf4j, ... to 2.0.11 (#938)
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
2024-01-14 02:58:19 +01:00
kerr
72f0a426b8
feat: Add support for for comprehensions. (#935) 2024-01-14 00:39:44 +08:00
PJ Fanning
6883d15576
use StandardCharsets (#934) 2024-01-13 12:40:16 +01:00
PJ Fanning
2ae6c8d00c
tidy up imports in new docker code (#930)
* tidy up imports in new docker code

* try to fix issues

* Update Dependencies.scala
2024-01-12 22:06:01 +01:00
Samuele Resca
b7be586e77
Replacing deprecated docker-client with docker-java (#922)
* Replacing deprecated docker-client with docker-java.

* Addressing feedback.

* Awaiting for image pull.

---------

Co-authored-by: Samuele Resca <sr7@ad.datcon.co.uk>
2024-01-12 16:12:23 +00:00
He-Pin
3f8be563b9 feat: Make SingleConsumerMultiProducer the default mailbox for stream. 2024-01-11 14:57:09 +08:00
He-Pin
ccce5c0426 feat: Optimize recoverWith stream operator for single source. 2024-01-10 02:57:44 +08:00
PJ Fanning
468aab0c63
reformat some headers (#921)
* reformat some headers

* add new line at EOF
2024-01-09 19:14:17 +01:00
Matthew de Detrich
b9d2cc6187 Use latest sbt-osgi 2024-01-09 19:00:34 +01:00
kerr
959c98dba5
chore: Fix typos in onErrorComplete.md (#916) 2024-01-08 13:19:00 +08:00
kerr
2b3818b55a
feat:Add onErrorComplete stream operator. (#913) 2024-01-08 02:30:52 +08:00
Matthew de Detrich
688eac7bf5 Add second sbt-osgi in dependency update ignore list 2024-01-07 04:13:22 +01:00
PJ Fanning
3f97d9fe04
jackson 2.16 support (#564)
* jackson 2.15 support

* Update JacksonObjectMapperProvider.scala

Update JacksonObjectMapperProvider.scala

Update JacksonObjectMapperProvider.scala

Update JacksonObjectMapperProvider.scala

* jackson 2.15.3

* jackson 2.16

* Update reference.conf

* add max-document-length

* Update .scala-steward.conf

* Update reference.conf

* 2.16.1

* Create JacksonFactorySpec.scala

* Update JacksonFactorySpec.scala

* add blank line
2024-01-06 20:07:03 +01:00
PJ Fanning
f361cb2f59
Create CHANGELOG.md (#909)
* Create CHANGELOG.md

* Update CHANGELOG.md
2024-01-06 16:47:26 +01:00
PJ Fanning
d5381958c8
fix ByteStringBuilder.addAll (#903)
* fix ByteStringBuilder.addAll

* sort out tests for different scala versions

* rework tests

* rework unmanaged source dirs
2024-01-04 12:21:13 +01:00
PJ Fanning
16e72eb396
Update build.sbt (#907) 2024-01-04 12:20:30 +01:00
Marco Zühlke
cda63179fc
Remove hard-coded scalafmt version (#901)
Since `scalafmt-native-action v3` the scalafmt version will be picked up from the `.scalafmt.conf` file.

Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
2024-01-04 10:40:53 +01:00
kerr
5cb7ad7d75
feat: Reimplement MapConcat operator without statefulMapConcat. (#902)
* feat: Reimplement MapConcat operator without statefulMapConcat.

* chore: sort imports

* chore: Remove the @inline annotation
2024-01-04 13:33:08 +08:00
Matthew de Detrich
ca64e66bc7 Fix Windows path issue with option-converters.excludes 2024-01-04 04:57:35 +01:00
Matthew de Detrich
f8c4aee8be Remove Scala 3 inline keyword from Java specific conversion methods 2024-01-01 01:55:16 +01:00
Matthew de Detrich
7ed85713e2 Fix header for Scala212CompatTest 2024-01-01 01:29:07 +01:00
PJ Fanning
d7f1b9058a
2024 added to copyright (#896) 2023-12-31 16:30:15 +01:00
Matthew de Detrich
3a605226df Fix scala-steward updating incorrect repo's 2023-12-31 09:54:35 +01:00
scala-steward-asf[bot]
4f8b16b217
Update jul-to-slf4j, log4j-over-slf4j, ... to 2.0.10 (#893)
Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
2023-12-31 09:44:10 +01:00
Matthew de Detrich
0f1db5301e Fix remaining missing inline statements/annotations 2023-12-30 07:13:27 +01:00
Matthew de Detrich
8cb7d256dc Remove @inline annotations and enable Scala 2 inliner 2023-12-30 03:41:12 +01:00
He-Pin
d829637ef2 chore: Fix RecipeAdhocSource test. 2023-12-28 17:58:37 +08:00
He-Pin
09023ce47a perf: Drop the usages of SupervisedGraphStageLogic to reduce allocation. 2023-12-28 15:56:48 +08:00
Matthew de Detrich
b818925edc Replace SubstreamCancelStrategy with SupervisionDecider for Split 2023-12-28 05:46:37 +01:00
He-Pin
c78e2d7610 chore: Add tests for not invoking onComplete twice for statefulMap operator. 2023-12-25 19:02:12 +08:00
He-Pin
413e79f5d3 chore: Fix GraphApply.scala.template 2023-12-25 12:49:47 +08:00
jxnu-liguobin
417196fb46
Optimize closeState flag (#872)
Co-authored-by: jxnu-liguobin <jxnu-liguobin@outlook.com>
2023-12-25 08:30:27 +08:00
He-Pin
16e587ded1 perf: Fold In&OutHanlder in FlatMapPrefix. 2023-12-24 22:15:54 +08:00
He-Pin
6b3096c28a chore: Add special null value handling doc for mapAsync and mapAsyncUnordered. 2023-12-24 16:34:00 +08:00
scala-steward-asf[bot]
d96e641896 Update aeron-client, aeron-driver to 1.43.0 2023-12-24 14:24:49 +08:00