diff options
| -rw-r--r-- | samples/src/main/scala/com/github/jodersky/flow/example/Main.scala | 3 | ||||
| -rw-r--r-- | src/main/scala/com/github/jodersky/flow/SerialOperator.scala | 1 |
2 files changed, 2 insertions, 2 deletions
diff --git a/samples/src/main/scala/com/github/jodersky/flow/example/Main.scala b/samples/src/main/scala/com/github/jodersky/flow/example/Main.scala index c25270b..021f638 100644 --- a/samples/src/main/scala/com/github/jodersky/flow/example/Main.scala +++ b/samples/src/main/scala/com/github/jodersky/flow/example/Main.scala @@ -35,7 +35,8 @@ object Main { serial ! ByteString(42) readLine() - //serial ! Close + serial ! "close" + readLine() system.shutdown() } diff --git a/src/main/scala/com/github/jodersky/flow/SerialOperator.scala b/src/main/scala/com/github/jodersky/flow/SerialOperator.scala index aa320e1..51cef39 100644 --- a/src/main/scala/com/github/jodersky/flow/SerialOperator.scala +++ b/src/main/scala/com/github/jodersky/flow/SerialOperator.scala @@ -42,7 +42,6 @@ class SerialOperator(serial: LowSerial, handler: ActorRef) extends Actor { } case Close => { - serial.close() sender ! Closed context.stop(self) } |