Ditto
Callbacks required to use the Ditto Bus API with explicit stream handles.
Functions
Link copied to clipboard
abstract fun dittoBusStreamDidAcknowledgeReceipt(busStream: DittoBusStream, messageSequence: BigInteger)
Content copied to clipboard
The remote peer has acknowledged receipt of all messages up to the given sequence number.
Link copied to clipboard
abstract fun dittoBusStreamDidClose(busStream: DittoBusStream, error: DittoError)
Content copied to clipboard
The stream has closed. This can be triggered by calling close() or by the remote peer doing the same.
Link copied to clipboard
abstract fun dittoBusStreamDidEnqueueDataWithMessageSequence( busStream: DittoBusStream, messageSequence: BigInteger, error: DittoError?)
Content copied to clipboard
The operation to enqueue outgoing data on a stream has completed. More data may now be enqueued.
Link copied to clipboard
abstract fun dittoBusStreamDidReceiveMessage(busStream: DittoBusStream, message: ByteArray)
Content copied to clipboard
A new message has been received from the specified stream.