=str Optimize concat for javadsl.Source.empty.

This commit is contained in:
He-Pin 2023-12-23 18:34:40 +08:00 committed by kerr
parent 873868c87b
commit 781b1226e7
2 changed files with 12 additions and 1 deletions

View file

@ -286,6 +286,17 @@ public class SourceTest extends StreamTest {
assertEquals(Arrays.asList("A", "B", "C", "D", "E", "F"), output);
}
@Test
public void mustBeAbleToConcatEmptySource() {
Source.from(Arrays.asList("A", "B", "C"))
.concat(Source.empty())
.runWith(TestSink.probe(system), system)
.ensureSubscription()
.request(3)
.expectNext("A", "B", "C")
.expectComplete();
}
@Test
public void mustBeAbleToUseConcatAll() {
final Source<Integer, NotUsed> sourceA = Source.from(Arrays.asList(1, 2, 3));