diff --git a/lib/delphi/src/Thrift.Transport.Pipes.pas b/lib/delphi/src/Thrift.Transport.Pipes.pas
index 593bb3a..47f3b4d 100644
--- a/lib/delphi/src/Thrift.Transport.Pipes.pas
+++ b/lib/delphi/src/Thrift.Transport.Pipes.pas
@@ -288,7 +288,7 @@
 
 procedure TPipeStreamBase.Flush;
 begin
-  // nothing to do
+  FlushFileBuffers( FPipe);
 end;