ZTCommand

open class ZTCommand(type: ZTCommand.Type)

ZTCommand

Author

Alexandre Lemoult <a.lemoult@zhortech.com>

Constructors

ZTCommand

fun ZTCommand(type: ZTCommand.Type)

Types

CommandAckPredicate

class CommandAckPredicate(predicate: AckFunPredicate, timeoutConfiguration: ZTCommand.TimeoutConfiguration?, error: Throwable?)

CommandPredicate

class CommandPredicate(predicate: FunPredicate)

CommandTimeoutConfigurationObservable

inner class CommandTimeoutConfigurationObservable(commandPredicate: ZTCommand.CommandPredicate?, timeoutConfiguration: ZTCommand.TimeoutConfiguration, error: Throwable)

Flag

open class Flag(byteValue: Byte)

TimeoutConfiguration

data class TimeoutConfiguration(timeout: Long, timeUnit: TimeUnit)

Type

open class Type(byteArray: ByteArray)

Functions

addAckFailed

fun addAckFailed(function: (cmdAck: ZTCommandAck) -> Boolean, error: Throwable): ZTCommand

addAckSuccess

fun addAckSuccess(function: (cmdAck: ZTCommandAck) -> Boolean, timeout: Long, timeUnit: TimeUnit, error: Throwable): ZTCommand

addExpect

fun addExpect(predicate: FunPredicate, timeout: Long, timeUnit: TimeUnit, error: Throwable): ZTCommand

checkCommand

fun checkCommand()

clean

fun clean()

equals

open operator override fun equals(other: Any?): Boolean

getArrayOfTimeoutsConfiguration

fun getArrayOfTimeoutsConfiguration(): MutableList<Completable>

getByteArray

fun getByteArray(): ByteArray

getCommandId

fun getCommandId(): Byte

getMessageType

fun getMessageType(): Byte?

getObservable

inline fun <T> getObservable(): T

hashCode

open override fun hashCode(): Int

isPairCommand

fun isPairCommand(): Boolean

observe

fun observe(): Completable

onAcknowledge

fun onAcknowledge(data: ByteArray)

onNext

fun onNext(data: ByteArray?): Boolean

onWriteError

fun onWriteError(error: Throwable)

onWriteSuccess

fun onWriteSuccess(data: ByteArray)

pair

fun pair(strategy: ZTPairResolutionStrategy): ZTCommand

setMessageType

fun setMessageType(messageType: Byte): ZTCommand

setTimeout

fun setTimeout(timeout: Long, timeUnit: TimeUnit): ZTCommand

withArgs

fun withArgs(buffer: ZTBuffer): ZTCommand

fun withArgs(vararg flags: ZTCommand.Flag): ZTCommand

fun withArgs(data: ByteArray): ZTCommand

Properties

commandCompletedSubject

val commandCompletedSubject: CompletableSubject

expectationsConfigurations

val expectationsConfigurations: MutableList<ZTCommand.CommandTimeoutConfigurationObservable>

id

val id: UUID

pairResolutionStrategy

var pairResolutionStrategy: ZTPairResolutionStrategy? = null

pairResult

var pairResult: ZTPair<Any, Any>? = null

pairSubject

var pairSubject: SingleSubject<ZTPair<Any, Any>>? = null

subject

val subject: SingleSubject<ByteArray>

type

val type: ZTCommand.Type

Inheritors

ZTCalibrationCommand