diff options
author | Jakob Odersky <jodersky@gmail.com> | 2014-04-03 19:22:59 +0200 |
---|---|---|
committer | Jakob Odersky <jodersky@gmail.com> | 2014-04-03 19:22:59 +0200 |
commit | d6d266693f2ab81db6abc35b28f00f1d72282338 (patch) | |
tree | 1732c5244f4225820ab976e29cefab1c8cc231fc | |
parent | bd33e17b3a11008cf3415d6dfc01f237f197bfe2 (diff) | |
download | akka-serial-d6d266693f2ab81db6abc35b28f00f1d72282338.tar.gz akka-serial-d6d266693f2ab81db6abc35b28f00f1d72282338.tar.bz2 akka-serial-d6d266693f2ab81db6abc35b28f00f1d72282338.zip |
fix: sending excessive, empty bytes
-rw-r--r-- | flow/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/flow/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala b/flow/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala index 3bdc7ec..74b7f23 100644 --- a/flow/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala +++ b/flow/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala @@ -103,8 +103,8 @@ class SerialConnection private ( writing = true try { transfer( - b => NativeSerial.writeDirect(pointer, b, b.remaining()), - b => NativeSerial.write(pointer, b.array(), b.remaining()))(buffer) + b => NativeSerial.writeDirect(pointer, b, b.position()), + b => NativeSerial.write(pointer, b.array(), b.position()))(buffer) } finally { writing = false if (closed.get) writeLock.notify() |