-
- All Implemented Interfaces:
-
com.polidea.rxandroidble2.internal.connection.ConnectionSubscriptionWatcher,com.polidea.rxandroidble2.internal.serialization.ClientOperationQueue,com.polidea.rxandroidble2.internal.serialization.ConnectionOperationQueue
public class ConnectionOperationQueueImpl implements ConnectionOperationQueue, ConnectionSubscriptionWatcher
-
-
Method Summary
Modifier and Type Method Description synchronized <T> Observable<T>queue(Operation<T> operation)Function that queues an Operation for execution. synchronized voidterminate(BleException disconnectException)A method for terminating all operations that are still queued on the connection. voidonConnectionSubscribed()Method to be called when the user subscribes to an individual establishConnection voidonConnectionUnsubscribed()Method to be called when the user disposes an individual establishConnection -
Methods inherited from class com.polidea.rxandroidble2.internal.serialization.ConnectionOperationQueue
terminate -
Methods inherited from class com.polidea.rxandroidble2.internal.serialization.ClientOperationQueue
queue -
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Method Detail
-
queue
synchronized <T> Observable<T> queue(Operation<T> operation)
Function that queues an Operation for execution.
- Parameters:
operation- the operation to execute
-
terminate
synchronized void terminate(BleException disconnectException)
A method for terminating all operations that are still queued on the connection.
-
onConnectionSubscribed
void onConnectionSubscribed()
Method to be called when the user subscribes to an individual establishConnection
-
onConnectionUnsubscribed
void onConnectionUnsubscribed()
Method to be called when the user disposes an individual establishConnection
-
-
-
-