Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add UnfoldResource ValueTask Stage and DSL methods #7028

Open
wants to merge 25 commits into
base: dev
Choose a base branch
from
+2,924 −6

Merge branch 'dev' into streams-valuetask-unfoldresource

cfbab88
Select commit
Loading
Failed to load commit list.
Open

Add UnfoldResource ValueTask Stage and DSL methods #7028

Merge branch 'dev' into streams-valuetask-unfoldresource
cfbab88
Select commit
Loading
Failed to load commit list.
Azure Pipelines / PR Validation failed Mar 20, 2024 in 41m 32s

Build #2024.3.20.1 had test failures

9 errors / 3 warnings

Details

Tests

  • Failed: 4 (0.06%)
  • Passed: 6,362 (96.12%)
  • Other: 253 (3.82%)
  • Total: 6,619

Annotations

Check failure on line 28954 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L28954 

Bash exited with code '42'.

Check failure on line 97121 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L97121 

Process completed with exit code 42.

Check failure on line 16 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L16 

Bash wrote one or more lines to the standard error stream.

Check failure on line 1 in Akka.Cluster.Tools.Tests.Singleton.ClusterSingletonRestart2Spec.Restarting_cluster_node_during_hand_over_must_restart_singletons_in_restarted_node

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Cluster.Tools.Tests.Singleton.ClusterSingletonRestart2Spec.Restarting_cluster_node_during_hand_over_must_restart_singletons_in_restarted_node 

Failed: Timeout 00:00:01 while waiting for a message of type Akka.Cluster.UniqueAddress
Raw output 
   at Akka.TestKit.Xunit2.XunitAssertions.Fail(String format, Object[] args) in D:\a\1\s\src\contrib\testkits\Akka.TestKit.Xunit2\XunitAssertions.cs:line 26
   at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`2 assert, String hint, CancellationToken cancellationToken, Boolean shouldLog) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 436
   at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 411
   at Akka.TestKit.TestKitBase.InternalExpectMsgAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 379
   at Akka.TestKit.TestKitBase.ExpectMsg[T](Nullable`1 duration, String hint, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 43
   at Akka.Cluster.Tools.Tests.Singleton.ClusterSingletonRestart2Spec.<>c__DisplayClass6_0.<Restarting_cluster_node_during_hand_over_must_restart_singletons_in_restarted_node>b__3() in D:\a\1\s\src\contrib\cluster\Akka.Cluster.Tools.Tests\Singleton\ClusterSingletonRestart2Spec.cs:line 121
   at Akka.TestKit.TestKitBase.AwaitAssertAsync(Action assertion, Nullable`1 duration, Nullable`1 interval, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_AwaitAssert.cs:line 57
   at Nito.AsyncEx.Synchronous.TaskExtensions.WaitAndUnwrapException(Task task)
   at Akka.TestKit.TestKitBase.AwaitAssert(Action assertion, Nullable`1 duration, Nullable`1 interval, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_AwaitAssert.cs:line 38
   at Akka.Cluster.Tools.Tests.Singleton.ClusterSingletonRestart2Spec.<>c__DisplayClass6_0.<Restarting_cluster_node_during_hand_over_must_restart_singletons_in_restarted_node>b__1() in D:\a\1\s\src\contrib\cluster\Akka.Cluster.Tools.Tests\Singleton\ClusterSingletonRestart2Spec.cs:line 114
   at Akka.TestKit.TestKitBase.<>c__DisplayClass216_0.<Within>b__0() in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Within.cs:line 44
   at Akka.TestKit.TestKitBase.WithinAsync[T](TimeSpan min, TimeSpan max, Func`1 function, String hint, Nullable`1 epsilonValue, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Within.cs:line 278
   at Akka.TestKit.TestKitBase.Within(TimeSpan max, Action action, Nullable`1 epsilonValue, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Within.cs:line 39
   at Akka.Cluster.Tools.Tests.Singleton.ClusterSingletonRestart2Spec.Restarting_cluster_node_during_hand_over_must_restart_singletons_in_restarted_node() in D:\a\1\s\src\contrib\cluster\Akka.Cluster.Tools.Tests\Singleton\ClusterSingletonRestart2Spec.cs:line 112
   at System.RuntimeMethodHandle.InvokeMethod(Object target, Void** arguments, Signature sig, Boolean isConstructor)
   at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)

Check failure on line 1 in Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_restart_on_completion

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_restart_on_completion 

System.Exception : [ExpectNextN] expected 2 next elements but received 1 elements before an exception occured. Received: [out complete]
---- Failed: Timeout 00:00:03 while waiting for a message of type Akka.Streams.TestKit.TestSubscriber+OnNext`1[System.String]
Raw output 
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber_Shared.cs:line 214
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+System.Threading.Tasks.Sources.IValueTaskSource<System.Boolean>.GetResult()
   at System.Linq.AsyncEnumerable.<ToListAsync>g__Core|424_0[TSource](IAsyncEnumerable`1 source, CancellationToken cancellationToken) in /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToList.cs:line 36
   at System.Linq.AsyncEnumerable.<ToListAsync>g__Core|424_0[TSource](IAsyncEnumerable`1 source, CancellationToken cancellationToken) in /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToList.cs:line 36
   at Akka.Streams.Tests.Dsl.RestartSpec.<A_restart_with_backoff_flow_should_restart_on_completion>b__35_0() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/RestartSpec.cs:line 883
   at Akka.Streams.TestKit.Utils.<>c__DisplayClass5_0.<<AssertAllStagesStoppedAsync>b__0>d.MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/Utils.cs:line 59
--- End of stack trace from previous location ---
   at Akka.TestKit.Extensions.TaskExtensions.<>c__DisplayClass5_0`1.<<ShouldCompleteWithin>b__0>d.MoveNext()
--- End of stack trace from previous location ---
   at FluentAssertions.Specialized.GenericAsyncFunctionAssertions`1.CompleteWithinAsync(TimeSpan timeSpan, String because, Object[] becauseArgs)
   at Akka.TestKit.Extensions.TaskExtensions.ShouldCompleteWithin[T](Task`1 task, TimeSpan timeout, String because, Object[] becauseArgs)
   at Akka.Streams.TestKit.Utils.AssertAllStagesStoppedAsync[T](TestKitBase spec, Func`1 block, IMaterializer materializer, Nullable`1 timeout, CancellationToken cancellationToken)
   at Akka.Streams.TestKit.Utils.AssertAllStagesStoppedAsync(TestKitBase spec, Func`1 block, IMaterializer materializer, Nullable`1 timeout, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/Utils.cs:line 57
   at Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_restart_on_completion() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/RestartSpec.cs:line 869
--- End of stack trace from previous location ---
----- Inner Stack Trace -----
   at Akka.TestKit.Xunit2.XunitAssertions.Fail(String format, Object[] args) in /home/vsts/work/1/s/src/contrib/testkits/Akka.TestKit.Xunit2/XunitAssertions.cs:line 26
   at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`2 assert, String hint, CancellationToken cancellationToken, Boolean shouldLog) in /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 436
   at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 411
   at Akka.TestKit.TestKitBase.InternalExpectMsgAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 379
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber_Shared.cs:line 209

Check failure on line 1 in Akka.Cluster.Tools.Tests.MultiNode.PublishSubscribe.DistributedPubSubRestartSpec.DistributedPubSubRestartSpecs

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Cluster.Tools.Tests.MultiNode.PublishSubscribe.DistributedPubSubRestartSpec.DistributedPubSubRestartSpecs 

Test failed

Check failure on line 1 in Akka.Streams.Tests.Dsl.UnfoldResourceValueTaskAsyncSourceSpec.A_UnfoldResourceValueTaskAsyncSource_must_close_resource_when_stream_is_quickly_cancelled_reproducer_2

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.Dsl.UnfoldResourceValueTaskAsyncSourceSpec.A_UnfoldResourceValueTaskAsyncSource_must_close_resource_when_stream_is_quickly_cancelled_reproducer_2 

Expected task to complete within 3s.
Raw output 
   at FluentAssertions.Execution.XUnit2TestFramework.Throw(String message)
   at FluentAssertions.Execution.AssertionScope.FailWith(Func`1 failReasonFunc)
   at FluentAssertions.Specialized.GenericAsyncFunctionAssertions`1.<CompleteWithinAsync>d__4.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Akka.TestKit.Extensions.TaskExtensions.<ShouldCompleteWithin>d__5`1.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Akka.Streams.Tests.Dsl.UnfoldResourceValueTaskAsyncSourceSpec.<<A_UnfoldResourceValueTaskAsyncSource_must_close_resource_when_stream_is_quickly_cancelled_reproducer_2>b__21_0>d.MoveNext() in D:\a\1\s\src\core\Akka.Streams.Tests\Dsl\UnfoldResourceValueTaskAsyncSourceSpec.cs:line 527
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Akka.Streams.TestKit.Utils.<>c__DisplayClass5_0.<<AssertAllStagesStoppedAsync>b__0>d.MoveNext() in D:\a\1\s\src\core\Akka.Streams.TestKit\Utils.cs:line 60
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Akka.TestKit.Extensions.TaskExtensions.<>c__DisplayClass5_0`1.<<ShouldCompleteWithin>b__0>d.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at FluentAssertions.Specialized.GenericAsyncFunctionAssertions`1.<CompleteWithinAsync>d__4.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Akka.TestKit.Extensions.TaskExtensions.<ShouldCompleteWithin>d__5`1.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Akka.Streams.TestKit.Utils.<AssertAllStagesStoppedAsync>d__6`1.MoveNext() in D:\a\1\s\src\core\Akka.Streams.TestKit\Utils.cs:line 72
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Akka.Streams.TestKit.Utils.<AssertAllStagesStoppedAsync>d__5.MoveNext() in D:\a\1\s\src\core\Akka.Streams.TestKit\Utils.cs:line 57
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Akka.Streams.Tests.Dsl.UnfoldResourceValueTaskAsyncSourceSpec.<A_UnfoldResourceValueTaskAsyncSource_must_close_resource_when_stream_is_quickly_cancelled_reproducer_2>d__21.MoveNext() in D:\a\1\s\src\core\Akka.Streams.Tests\Dsl\UnfoldResourceValueTaskAsyncSourceSpec.cs:line 509
--- End of stack trace from previous location where exception was thrown ---
   at
View more details on Azure Pipelines