StreamsJava

interface StreamsJava

Functions

Link copied to clipboard
open fun create(uniqueName: String?, ttlSeconds: Long, output: SuccessListener<SyncStreamJava>): CancellationToken
abstract fun create(uniqueName: String?, ttlSeconds: Long, listener: SyncStreamJava.Listener?, output: SuccessListener<SyncStreamJava>): CancellationToken

Create new SyncStreamJava object.

Link copied to clipboard
abstract fun openExisting(sidOrUniqueName: String, listener: SyncStreamJava.Listener? = null, output: SuccessListener<SyncStreamJava>): CancellationToken

Open existing SyncStreamJava by SID or unique name.

Link copied to clipboard
open fun openOrCreate(uniqueName: String, ttlSeconds: Long, output: SuccessListener<SyncStreamJava>): CancellationToken
abstract fun openOrCreate(uniqueName: String, ttlSeconds: Long, listener: SyncStreamJava.Listener?, output: SuccessListener<SyncStreamJava>): CancellationToken

Open existing SyncStreamJava by unique name or create a new one if specified name does not exist.

Link copied to clipboard
abstract fun publishMessage(sidOrUniqueName: String, jsonData: String, callback: SuccessListener<SyncStreamJava.Message>): CancellationToken

Publish a new message to SyncStreamJava without opening it.

Link copied to clipboard
abstract fun remove(sidOrUniqueName: String, callback: SuccessListener<Unit>): CancellationToken

Remove SyncStreamJava without opening it.

Link copied to clipboard
abstract fun setTtl(sidOrUniqueName: String, ttlSeconds: Long, callback: SuccessListener<Unit>): CancellationToken

Set time to live for SyncStreamJava without opening it.