object Serial extends ExtensionId[SerialExt] with ExtensionIdProvider
Defines messages used by akka-serial's serial IO layer.
- Alphabetic
- By Inheritance
- Serial
- ExtensionIdProvider
- ExtensionId
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- trait Command extends Message
A message extending this trait is to be viewed as a command, an out-bound message issued by the client to akka-serial's API.
- case class CommandFailed(command: Command, reason: Throwable) extends Event with Product with Serializable
A command has failed.
- case class Connected(port: String) extends Event with Product with Serializable
A new port (i.e.
A new port (i.e. file) has been detected.
- port
the absolute file name of the connected port
- trait Event extends Message
A message extending this trait is to be viewed as an event, an in-bound message issued by akka-serial to the client.
- sealed trait Message extends AnyRef
Base trait for any akka-serial-related messages.
- case class Open(port: String, settings: SerialSettings, bufferSize: Int = 1024) extends Command with Product with Serializable
Open a new serial port.
Open a new serial port.
Send this command to the serial manager to request the opening of a serial port. The manager will attempt to open a serial port with the specified parameters and, if successful, create a
SerialOperator
actor associated to the port. The operator actor acts as an intermediate to the underlying native serial port, dealing with threading issues and dispatching messages.In case the port is successfully opened, the operator will respond with an
Opened
message. In case the port cannot be opened, the manager will respond with aCommandFailed
message.- port
name of serial port to open
- settings
settings of serial port to open
- bufferSize
maximum read and write buffer sizes
- case class Opened(port: String) extends Event with Product with Serializable
A port has been successfully opened.
A port has been successfully opened.
Event sent by a port operator, indicating that a serial port was successfully opened. The sender of this message is the operator associated to the given serial port.
- port
name of opened serial port
- case class Received(data: ByteString) extends Event with Product with Serializable
Data has been received.
Data has been received.
Event sent by an operator, indicating that data was received on the operator's serial port.
- data
data received on the port
- case class Unwatch(directory: String = "/dev") extends Command with Product with Serializable
Stop receiving notifications about a previously watched directory.
Stop receiving notifications about a previously watched directory.
- directory
the directory to unwatch
- case class Watch(directory: String = "/dev", skipInitial: Boolean = false) extends Command with Product with Serializable
Watch a directory for new ports.
Watch a directory for new ports.
Send this command to the manager to get notifications when a new port (i.e. file) is created in the given directory. In case the given directory cannot be watched, the manager responds with a
CommandFailed
message.Note: the sender is also notified of currently existing ports.
- directory
the directory to watch
- skipInitial
don't get notified of already existing ports
- See also
Unwatch
Connected
- case class Write(data: ByteString, ack: (Int) => Event = NoAck) extends Command with Product with Serializable
Write data to a serial port.
Write data to a serial port.
Send this command to an operator to write the given data to its associated serial port. An acknowledgment may be set, in which case it is sent back to the sender on a successful write. Note that a successful write does not guarantee the actual transmission of data through the serial port, it merely guarantees that the data has been stored in the operating system's kernel buffer, ready to be transmitted.
- data
data to be written to port
- ack
acknowledgment sent back to sender once data has been enqueued in kernel for sending (the acknowledgment is a function 'number of bytes written => event')
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##(): Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def apply(system: ActorSystem): SerialExt
- Definition Classes
- ExtensionId
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def createExtension(system: ExtendedActorSystem): SerialExt
- Definition Classes
- Serial → ExtensionId
- def debug(value: Boolean): Unit
Sets native debugging mode.
Sets native debugging mode. If debugging is enabled, detailed error messages are printed (to stderr) from native method calls.
- value
set to enable debugging
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def equals(other: Any): Boolean
- Definition Classes
- ExtensionId → AnyRef → Any
- def get(system: ActorSystem): SerialExt
- Definition Classes
- Serial → ExtensionId
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def hashCode(): Int
- Definition Classes
- ExtensionId → AnyRef → Any
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def lookup(): Serial
- Definition Classes
- Serial → ExtensionIdProvider
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- object Close extends Command with Product with Serializable
Request closing of port.
Request closing of port.
Send this command to an operator to close its associated port. The operator will respond with a
Closed
message upon closing the serial port. - object Closed extends Event with Product with Serializable
A port has been closed.
A port has been closed.
Event sent from operator, indicating that its port has been closed.
- object NoAck extends (Int) => Event with Product with Serializable
Special type of acknowledgment that is not sent back.
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.