¿Cómo leer cada nueva línea del archivo después de 10 segundos de retraso con Akka?

Estoy tratando de leer el archivo línea por línea con cierto retraso.

Por ejemplo:

  • lee e imprime la primera línea del archivo
  • espera 10 segundos
  • leer e imprimir la segunda línea del archivo
  • etc.

Hasta ahora he intentado algo como esto:

final Path filePath = Paths.get('path/to/file');
final ActorSystem system = ActorSystem.create();
final Materializer materializer = ActorMaterializer.create(system);

Sink<ByteString, CompletionStage<Done>> printlnSink =
   Sink.<ByteString>foreach(chunk -> System.out.println(chunk.utf8String()));

final CompletionStage<IOResult> result = 
  FileIO.fromPath(filePath)
 .throttle(1, Duration.create(10, TimeUnit.SECONDS), 1, ThrottleMode.shaping())
 .to(printlnSink)
 .run(materializer);

Pero esto estalla demasiadas líneas a la vez y no una línea a la vez.

¿Alguna idea para solucionarlo?

Respuesta 1

Tengo el siguiente código que funciona en eclipse 3.7: IEditorReference privado getReference (parte IEditorPart) {return (IEditorReference) ((PartSite) part.getSite ()). GetPane () ...

Estoy tratando de encontrar un elemento web en Chrome con la ayuda de Selenium WebDriver. Cuando el controlador inicia la URL, se muestra una lista de proyectos y el controlador tiene que seleccionar un proyecto específico ...

Tengo 2 servicios (servicio1 y servicio2), y ambos servicios usan el mismo modelo de datos "studentModel", me pregunto cómo compartir el studentModel entre los dos servicios. 1.Construye un modelo de estudiante ...

Estoy obligado a ingresar la hora de inicio y la hora de finalización y en swing java que enviaré a una URL para obtener algunos nodos seleccionados creados en este momento mediante la llamada GET REST. La URL es: http: //wisekar.iitd ....