Johan Andrén

Grouped per context operator

2

A neat thing for streams with context would be if there was an operator that would group until the context changes and emit a tuple of context and the collected...

Not entirely sure this is the right thing but in https://github.com/akka/akka-http/pull/4289 we noticed that `StreamIdleTimeoutException`s in the stream not originating from the TCP idle timeouts would still be turned into...

Refs #32134 Wanted to fail fast with a better error message but could not find a definitive way to know a path is a fifo from Java, the closest is...

Illegal seek for FileIO.fromPath with named pipe

4

> It seems to be not working for me (tried with mulitple versions): ```Error during preStart in [FileSource(/tmp/adsb, 8192)]: Illegal seek java.io.IOException: Illegal seek at java.base/sun.nio.ch.FileDispatcherImpl.seek0(Native Method) at java.base/sun.nio.ch.FileDispatcherImpl.seek(FileDispatcherImpl.java:78) at...

Failed: ClusterSingletonManagerSpec

3

https://github.com/akka/akka/actions/runs/6167095988/job/16737547153#step:10:33912 ``` [info] [JVM-6] - must startup 6 node cluster (on node 'fourth', class akka.cluster.singleton.ClusterSingletonManagerMultiJvmNode6) *** FAILED *** [info] [JVM-6] java.lang.AssertionError: assertion failed: timeout (2 seconds) during expectMsg while waiting...

just seeing that it can be pulled and compile protos for now

Failed: Multiple tests error dialing backend: No agent available

1

Multi node tests failing (https://github.com/akka/akka/actions/runs/5971037115/job/16199491528) with a bunch of these: ``` 2023-08-25T03:32:23.6685227Z [error] Error from server: error dialing backend: No agent available 2023-08-25T03:32:24.3025443Z [error] Error from server: error dialing backend:...

Multi jvm nightlies, https://github.com/akka/akka/actions/runs/5994767303/job/16256813652 `PersistentClusterShardingRememberEntitiesEnabledMultiJvm`, Not sure what on earth is going on here: ``` 2023-08-28T03:40:30.3835236Z [error] E0828 03:40:30.383025 87965 v2.go:104] write tcp 10.1.0.101:45036->35.238.55.169:443: write: connection reset by peer 2023-08-28T03:40:32.2969649Z...

Fail: akka.stream.io.FileSinkSpec

12

https://github.com/akka/akka/actions/runs/4179274173/jobs/7239028718#step:5:18284 Seems similar to #31584 ``` [02-15 00:49:05.554] [info] - must allow overriding the dispatcher using Attributes *** FAILED *** (18 milliseconds) [02-15 00:49:05.554] [info] java.lang.AssertionError: Expected Actor[akka://FileSinkSpec/system/Materializers/StreamSupervisor-1876/flow-21-2-fileSink#752598869] to use...

Failed: ReliableDeliveryShardingSpec:

1

https://github.com/akka/akka/actions/runs/4338698262/jobs/7575589158 ``` 023-03-06T01:07:25.3759649Z