ditto/live.ditto.transports.ble/CommandQueue

CommandQueue

class CommandQueue<T>(handler: Handler, callbacks: CommandQueueCallback<T>, operationTimeout: Long) : ConcurrentLinkedQueue<T>

Constructors

CommandQueue

constructor(handler: Handler, callbacks: CommandQueueCallback<T>, operationTimeout: Long)

Types

Companion

object Companion

Properties

pendingOperation

@Volatile

var pendingOperation: T?

size

open override val size: Int

Functions

add

open override fun add(element: T): Boolean

addAll

open override fun addAll(elements: Collection<T>): Boolean

clear

@Synchronized

open override fun clear()

completePendingCommand

@Synchronized

fun completePendingCommand()

Finish a pending operation, often called in an Android callback.

contains

open operator override fun contains(element: T): Boolean

containsAll

open override fun containsAll(elements: Collection<T>): Boolean

element

open override fun element(): T

enqueueCommand

@Synchronized

fun enqueueCommand(operation: T)

Adds an operation onto the queue, see the BleOperationType class for more details.

forEach

open override fun forEach(p0: Consumer<in T>)

isEmpty

open override fun isEmpty(): Boolean

iterator

open operator override fun iterator(): MutableIterator<T>

offer

open override fun offer(p0: T): Boolean

parallelStream

open fun parallelStream(): Stream<T>

peek

open override fun peek(): T

poll

open override fun poll(): T

remove

open override fun remove(): T

open override fun remove(element: T): Boolean

removeAll

open override fun removeAll(elements: Collection<T>): Boolean

removeIf

open override fun removeIf(p0: Predicate<in T>): Boolean

removeIfCompat

fun <E> ConcurrentLinkedQueue<E>.removeIfCompat(filter: (E) -> Boolean)

retainAll

open override fun retainAll(elements: Collection<T>): Boolean

spliterator

open override fun spliterator(): Spliterator<T>

stream

open fun stream(): Stream<T>

toArray

open override fun toArray(): Array<Any>

open override fun <T : Any> toArray(p0: Array<T>): Array<T>

open fun <T : Any> ~~toArray~~(p0: IntFunction<Array<T>>): Array<T>

toString

open override fun toString(): String