adds a Start request to the req listener
This commit is contained in:
+7
-1
@@ -148,7 +148,13 @@ class PoolRequests {
|
|||||||
cmd: Command,
|
cmd: Command,
|
||||||
) {
|
) {
|
||||||
when (cmd) {
|
when (cmd) {
|
||||||
is ReqCmd -> subState(cmd.subId).onOpenReq(relay, cmd.filters)
|
is ReqCmd -> {
|
||||||
|
subState(cmd.subId).onOpenReq(relay, cmd.filters)
|
||||||
|
desiredSubListeners.get(cmd.subId)?.onStartReq(
|
||||||
|
relay = relay.url,
|
||||||
|
forFilters = cmd.filters,
|
||||||
|
)
|
||||||
|
}
|
||||||
is CloseCmd -> subState(cmd.subId).onCloseReq(relay)
|
is CloseCmd -> subState(cmd.subId).onCloseReq(relay)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+5
@@ -48,4 +48,9 @@ interface IRequestListener {
|
|||||||
message: String,
|
message: String,
|
||||||
forFilters: List<Filter>?,
|
forFilters: List<Filter>?,
|
||||||
) {}
|
) {}
|
||||||
|
|
||||||
|
fun onStartReq(
|
||||||
|
relay: String,
|
||||||
|
forFilters: List<Filter>,
|
||||||
|
) {}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user