stream4.php

<?php
header("X-Accel-Buffering: no");
header("Content-Type: text/event-stream");
header("Cache-Control: no-cache");
$pipe = "/tmp/pipe2.pipe";


$f = fopen($pipe, "r");
if (!$f) {
    echo "data: Failed to open pipe!\n\n";
    flush();
    exit;
}
//exec('sleep 10 > /dev/null &; echo "test14" > /tmp/pipe2.pipe > /dev/null &');
$data = '';
while (true) {
    
  // Every min, send a "ping" event.

  echo "event: ping\n\n";

  $listen=true;
    $i=10;
  while($i > 0)
{
    $chunk = fread($f, 1024);
    if ($chunk !== false && strlen($chunk) > 0) {
        $data .= $chunk;
        unset($chunk);
        $listen=false;
    }
    //usleep(200000); // sleep 200ms before trying again
    sleep(1);
    $i--;
    //$listen=false;
    //fclose($f);
    }
  
    if (strlen(trim($data)) > 0) {
        //echo "retry: 120000\n";
        //echo "event: update\n";
        //using the data tag here mans grouped messages get misseed.
        echo "data: " . trim($data) . "\n\n";
        $listen=true;
        $data = '';
    }
    
  if (ob_get_contents()) {
      ob_end_flush();
  }
  flush();

  // Break the loop if the client aborted the connection (closed the page)

  if (connection_aborted()) break;

  //sleep(3);
}
fclose($f);
?>