diff --git a/core/src/main/scala/transport/netty/Client.scala b/core/src/main/scala/transport/netty/Client.scala
index 194059b..2e26cf8 100644
--- a/core/src/main/scala/transport/netty/Client.scala
+++ b/core/src/main/scala/transport/netty/Client.scala
@@ -70,7 +70,7 @@ object NettyTransport {
                    })
   }
 
-  def write(c: Channel)(frame: Framed): Task[Unit] = evalCF(c.write(frame))
+  def write(c: Channel)(frame: Framed): Task[Unit] = evalCF(c.writeAndFlush(frame))
 
   def single(host: InetSocketAddress,
              expectedSigs: Set[Signature] = Set.empty,
diff --git a/core/src/main/scala/transport/netty/Transport.scala b/core/src/main/scala/transport/netty/Transport.scala
index 13a7237..75d1bc4 100644
--- a/core/src/main/scala/transport/netty/Transport.scala
+++ b/core/src/main/scala/transport/netty/Transport.scala
@@ -126,7 +126,7 @@ class Deframe extends ByteToMessageDecoder {
           } else {
             remaining = Some(rem)
           }
-        } 
+        }
       case Some(rem) =>
         // we are waiting for at least rem more bytes, as that is what
         // is outstanding in the current frame
@@ -177,9 +177,9 @@ object Enframe extends ChannelOutboundHandlerAdapter {
     obj match {
       case Bits(bv) =>
         val byv = bv.toByteVector
-        val _ = ctx.writeAndFlush(Unpooled.wrappedBuffer((codecs.int32.encode(byv.size).require ++ bv).toByteBuffer), cp)
+        val _ = ctx.write(Unpooled.wrappedBuffer((codecs.int32.encode(byv.size).require ++ bv).toByteBuffer), cp)
       case EOS =>
-        val _ = ctx.writeAndFlush(Unpooled.wrappedBuffer(codecs.int32.encode(0).require.toByteBuffer), cp)
+        val _ = ctx.write(Unpooled.wrappedBuffer(codecs.int32.encode(0).require.toByteBuffer), cp)
       case x => throw new IllegalArgumentException("was expecting Framed, got: " + x)
     }
   }