update resumable file transfer example

mostroverkhov · mostroverkhov · commit d9e494458be6 · 2019-09-17T15:28:08.000+03:00
Signed-off-by: Maksym Ostroverkhov &lt;m.ostroverkhov@gmail.com&gt;
diff --git a/rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/resume/ResumeFileTransfer.java b/rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/resume/ResumeFileTransfer.java
@@ -17,6 +17,8 @@
 import reactor.core.publisher.Mono;
 
 public class ResumeFileTransfer {
+  /*amount of file chunks requested by subscriber: n, refilled on n/2 of received items*/
+  private static final int PREFETCH_WINDOW_SIZE = 4;
 
   public static void main(String[] args) {
     RequestCodec requestCodec = new RequestCodec();
@@ -43,7 +45,7 @@ public static void main(String[] args) {
     client
         .requestStream(requestCodec.encode(new Request(16, "lorem.txt")))
         .doFinally(s -> server.dispose())
-        .subscribe(Files.fileSink("rsocket-examples/out/lorem_output.txt", 256));
+        .subscribe(Files.fileSink("rsocket-examples/out/lorem_output.txt", PREFETCH_WINDOW_SIZE));
 
     server.onClose().block();
   }
