Skip to content
This repository was archived by the owner on Nov 22, 2024. It is now read-only.

Testkit sink write#1065

Merged
RayRoestenburg merged 9 commits into
mainfrom
testkit_sink_write
Jun 15, 2021
Merged

Testkit sink write#1065
RayRoestenburg merged 9 commits into
mainfrom
testkit_sink_write

Conversation

@RayRoestenburg

Copy link
Copy Markdown
Contributor

What changes were proposed in this pull request?

Fixes #1054
#1033

Why are the changes needed?

See referenced issues.

Does this PR introduce any user-facing change?

A testkit sinkRef.write does not cause a Completed message anymore. The Completed message is only sent when the stream has completed. Internally, every sinkRef.write returns a Future that is completed when the element is written to the Sink.

How was this patch tested?

The test that showed the issue is added to the repo, thanks @thomasschoeftner !

@RayRoestenburg RayRoestenburg requested a review from andreaTP June 14, 2021 11:29
@RayRoestenburg RayRoestenburg requested a review from debasishg June 14, 2021 13:54
@@ -0,0 +1,97 @@
/*
* Copyright (C) 2016-2020 Lightbend Inc. <https://www.lightbend.com>

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

2016-2021 ?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Good catch

@debasishg debasishg left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@RayRoestenburg RayRoestenburg merged commit d01c518 into main Jun 15, 2021
@RayRoestenburg RayRoestenburg deleted the testkit_sink_write branch June 15, 2021 15:29
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Testkit can change ordering of elements emitted via sinkRef.write

2 participants