pjfanning merged PR #259:
URL: https://github.com/apache/pekko-projection/pull/259
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubsc
pjfanning commented on PR #1709:
URL: https://github.com/apache/pekko/pull/1709#issuecomment-2705677840
I don't think this should go into 1.1.4.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to th
MartinHH commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1984550609
##
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Switch.scala:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
MartinHH commented on PR #1787:
URL: https://github.com/apache/pekko/pull/1787#issuecomment-2705688990
> @pjfanning @MartinHH BTW, the Kotlin flow is using `flatmapLatest` as a
`switchMap`, I'm not sure which name is better, maybe `switchMap` is good
enough?
I'm kind of biased to the
pjfanning opened a new pull request, #151:
URL: https://github.com/apache/pekko-site/pull/151
vote has passed and release is being pushed out
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the s
pjfanning opened a new issue, #261:
URL: https://github.com/apache/pekko-projection/issues/261
Consistently failing in all builds the last week or 2.
```
[info] MSSQLServerJdbcOffsetStoreSpec:
2025-03-07 06:53:14.203Z warn [SQLServerConnection] ConnectionID:1
ClientConnectionId
pjfanning commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1984575324
##
docs/src/main/paradox/stream/operators/Source-or-Flow/switchMap.md:
##
@@ -11,8 +11,9 @@ Transforms each input element into a `Source` of output
elements that is th
MartinHH commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1984576698
##
docs/src/main/paradox/stream/operators/Source-or-Flow/switchMap.md:
##
@@ -0,0 +1,29 @@
+# switchMap
+
+Transforms each input element into a `Source` of output elemen
The GitHub Actions job "Nightly Integration Tests for JDBC (Pekko 1.0.x)" on
pekko-projection.git has failed.
Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run:
653e9b6a79cc240ef660628cdd61a4bcbba9a8d8 / scala-steward-asf[bot]
<147768647+scala-steward-asf[bot]@
He-Pin commented on PR #1709:
URL: https://github.com/apache/pekko/pull/1709#issuecomment-2705389291
@pjfanning Do you think we should have this in 1.1.4? seems we need more
time to publish 1.2.0
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
He-Pin commented on PR #1787:
URL: https://github.com/apache/pekko/pull/1787#issuecomment-2705384610
I'm Ok with the current shape too, which we can polish it later, but let's
wait a little longer for @MartinHH if he has some more updates, wdyt.
I would also like to have https://githu
dependabot[bot] closed pull request #1772: chore(deps): bump
VirtusLab/scala-cli-setup from 1.5.4 to 1.6.2
URL: https://github.com/apache/pekko/pull/1772
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
MartinHH commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1984550609
##
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Switch.scala:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
He-Pin opened a new issue, #1790:
URL: https://github.com/apache/pekko/issues/1790
This is a meta issue, I will collect the operators needed to implement
something like Spring Ai.
[WIP] `switchMap` https://github.com/apache/pekko/pull/1787
--
This is an automated message from the A
The GitHub Actions job "Nightly Build and Test" on pekko-connectors-kafka.git
has failed.
Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run:
9ca2e9e926a910409fdcfcdb00659cf4ec9478ff / scala-steward-asf[bot]
<147768647+scala-steward-asf[bot]@users.noreply.github
He-Pin commented on PR #1787:
URL: https://github.com/apache/pekko/pull/1787#issuecomment-2705734055
@MartinHH Yes, I see the code in Spring Ai, which is using Flux#switchMap
too. Thanks for the input.
--
This is an automated message from the Apache Git Service.
To respond to the message,
He-Pin commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1984586936
##
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala:
##
@@ -2804,6 +2804,25 @@ trait FlowOps[+Out, +Mat] {
def flattenMerge[T, M](breadth: Int)(implici
dependabot[bot] opened a new pull request, #1789:
URL: https://github.com/apache/pekko/pull/1789
Bumps
[VirtusLab/scala-cli-setup](https://github.com/virtuslab/scala-cli-setup) from
1.5.4 to 1.7.0.
Release notes
Sourced from https://github.com/virtuslab/scala-cli-setup/releases";>
dependabot[bot] commented on PR #1772:
URL: https://github.com/apache/pekko/pull/1772#issuecomment-2705268650
Superseded by #1789.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific com
The GitHub Actions job "Publish 1.0 Nightly" on pekko-grpc.git has failed.
Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run:
16d111979980d10b4c38b27bca12d445d8efe3d2 / scala-steward-asf[bot]
<147768647+scala-steward-asf[bot]@users.noreply.github.com>
Update sca
He-Pin commented on PR #1787:
URL: https://github.com/apache/pekko/pull/1787#issuecomment-2705649175
@pjfanning @MartinHH BTW, the Kotlin flow is using `flatmapLatest` as a
`switchMap`, I'm not sure which name is better, maybe `switchMap` is good
enough?
--
This is an automated message
The GitHub Actions job "Nightly Builds" on pekko.git has failed.
Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run:
ba05791fa0ea347a5c6ac417bdd6c080b305e363 / He-Pin(kerr)
chore: Handle NormalShutdownReason in MergeHub (#1741)
Report URL: https://github.com/apa
He-Pin merged PR #1788:
URL: https://github.com/apache/pekko/pull/1788
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@pekko.a
The GitHub Actions job "Integration Tests for Slick" on pekko-projection.git
has failed.
Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run:
4919e910260eed2b255904f81e99108b4ea94e89 / PJ Fanning
release notes for 1.1.0 (#259)
* release notes for 1.1.0
* Updat
The GitHub Actions job "Integration Tests for JDBC" on pekko-projection.git has
failed.
Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run:
4919e910260eed2b255904f81e99108b4ea94e89 / PJ Fanning
release notes for 1.1.0 (#259)
* release notes for 1.1.0
* Update
He-Pin commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1983220056
##
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Switch.scala:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
He-Pin commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1983223893
##
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Switch.scala:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
He-Pin commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1983224383
##
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Switch.scala:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
He-Pin commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1983217646
##
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Switch.scala:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
He-Pin commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1983216569
##
docs/src/main/paradox/stream/operators/Source-or-Flow/switchMap.md:
##
@@ -0,0 +1,29 @@
+# switchMap
+
+Transforms each input element into a `Source` of output elements
He-Pin commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1983219028
##
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Switch.scala:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
He-Pin commented on PR #1787:
URL: https://github.com/apache/pekko/pull/1787#issuecomment-2703636619
Thank you for this. I have some pr that avoids the materialization of
subSource, which you can refer to.
https://github.com/apache/pekko/pull/1775
--
This is an automated messag
pjfanning commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1983940803
##
docs/src/main/paradox/stream/operators/Source-or-Flow/switchMap.md:
##
@@ -0,0 +1,29 @@
+# switchMap
+
+Transforms each input element into a `Source` of output eleme
pjfanning commented on code in PR #1787:
URL: https://github.com/apache/pekko/pull/1787#discussion_r1983950766
##
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Switch.scala:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
34 matches
Mail list logo
