adam/com.malinskiy.adam.request/AsyncChannelRequest

AsyncChannelRequest

abstract class AsyncChannelRequest<T, I>(val channel: ReceiveChannel<I>? = null, val target: Target = NonSpecifiedTarget, val socketIdleTimeout: Long? = null) : Request

Read and write are called in sequence, hence you have to give the control flow back if you want cooperative multitasking to happen

Inheritors

AsyncDeviceMonitorRequest

ChanneledShellCommandRequest

BasePullFileRequest

BasePushFileRequest

Constructors

AsyncChannelRequest

constructor(channel: ReceiveChannel<I>? = null, target: Target = NonSpecifiedTarget, socketIdleTimeout: Long? = null)

Functions

open suspend fun close(channel: SendChannel<T>)

Optionally send a message The transport connection is not available at this point

handshake

open suspend fun handshake(socket: Socket)

readElement

abstract suspend fun readElement(socket: Socket, sendChannel: SendChannel<T>): Boolean

Called after the initial OKAY confirmation

serialize

abstract fun serialize(): ByteArray

Some requests require a device serial to be passed to the request itself by means of

validate

open fun validate(): ValidationResponse

writeElement

abstract suspend fun writeElement(element: I, socket: Socket)

Called after each readElement

Properties

channel

val channel: ReceiveChannel<I>? = null

socketIdleTimeout

val socketIdleTimeout: Long? = null

target

val target: Target