Moves to a less memory intensive way to send filters to the server.
This commit is contained in:
@@ -279,10 +279,12 @@ class Relay(
|
|||||||
if (read) {
|
if (read) {
|
||||||
if (isConnected()) {
|
if (isConnected()) {
|
||||||
if (isReady) {
|
if (isReady) {
|
||||||
val filters = Client.getSubscriptionFilters(requestId).filter { activeTypes.intersect(it.types).isNotEmpty() }
|
val filters = Client.getSubscriptionFilters(requestId).filter { filter ->
|
||||||
|
activeTypes.any { it in filter.types }
|
||||||
|
}
|
||||||
if (filters.isNotEmpty()) {
|
if (filters.isNotEmpty()) {
|
||||||
val request =
|
val request =
|
||||||
"""["REQ","$requestId",${filters.take(10).joinToString(",") { it.filter.toJson(url) }}]"""
|
"""["REQ","$requestId",${filters.joinToString(",", limit = 10, truncated = "") { it.filter.toJson(url) }}]"""
|
||||||
|
|
||||||
// Log.d("Relay", "onFilterSent $url $requestId $request")
|
// Log.d("Relay", "onFilterSent $url $requestId $request")
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user