Add test for logs that is not sent in a single line

Author: danielbodart

packages/testcontainers/src/wait-strategies/log-wait-strategy.test.ts

@@ -56,17 +56,12 @@ describe("LogWaitStrategy", { timeout: 180_000 }, () => {
   });
 
 
-  it("should throw an error if the message is never received", async () => {
-    const containerName = `container-${new RandomUuid().nextUuid()}`;
-
-    await expect(
-      new GenericContainer("cristianrgreco/testcontainer:1.1.14")
-        .withName(containerName)
-        .withCommand("/bin/sh", "-c", 'echo "Ready"')
-        .withWaitStrategy(Wait.forLogMessage("unexpected"))
-        .start()
-    ).rejects.toThrowError(`Log stream ended and message "unexpected" was not received`);
+  it("does not matter if container does not send all content in a single line", async () => {
+    const container = await new GenericContainer("cristianrgreco/testcontainer:1.1.14")
+      .withCommand(["node", "-e", "process.stdout.write('Hello '); setTimeout(() => process.stdout.write('World\\n'), 2000)"])
+      .withWaitStrategy(Wait.forLogMessage("Hello World"))
+      .start();
 
-    expect(await getRunningContainerNames()).not.toContain(containerName);
+    await container.stop();
   });
-});
+});

packages/testcontainers/src/wait-strategies/log-wait-strategy.ts

@@ -31,6 +31,7 @@ export class LogWaitStrategy extends AbstractWaitStrategy {
 
     let matches = 0;
     for await (const chunk of stream) {
+      console.log(chunk)
       if (this.matches(chunk)) {
         if (++matches === this.times) {
           return log.debug(`Log wait strategy complete`, { containerId: container.id });