subscribe
fun subscribe(query: String, variables: Map<String, Any>? = null, operationName: String? = null): Flow<JsonElement>
Subscribe to GraphQL operation.
Returns: Flow of operation results (JsonElement)
Each result is emitted as received from server. Flow completes when server sends complete message. Flow errors if server sends error message.
Example:
val query = """
subscription {
unshieldedTransactions(address: "mn_addr_testnet1...") {
transaction { hash }
}
}
"""
client.subscribe(query).collect { result ->
println("Received: $result")
}Content copied to clipboard
Return
Flow of results
Parameters
query
GraphQL subscription query
variables
Query variables (optional)
operationName
Operation name (optional)
Throws
if not connected