kornerr/check-ios-bus
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

d

Browse Source
This commit is contained in:
Михаил Капелько
2024-01-18 18:46:09 +03:00
parent a7f5161e5e
commit 496c34a89f
3 changed files with 21 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
Modules/MicX/MicItem/src/MicItem.V.swift
View File

@@ -10,9 +10,9 @@ extension MicItem {
public init(_ id: String? = nil) { public init(_ id: String? = nil) {
self.id = id self.id = id
self.proc = [ self.proc = [
Bus.DelayV(shouldResetTimeout, K.MI, K.timeout), Bus.DelayV(shouldResetTimeout, K.MI, K.timeout, id),
Bus.Sync(shouldResetActivity, K.MI, K.isActive), Bus.Sync(shouldResetActivity, K.MI, K.isActive, id),
MicItem.Controller() MicItem.Controller(id)
] ]
} }

8
Modules/MicX/MicItem/src/MicItem.WillBe.swift
View File

@@ -15,7 +15,7 @@ extension MicItem {
extension MicItem { extension MicItem {
final class Controller: MPAK.Controller<MicItem.Model> { final class Controller: MPAK.Controller<MicItem.Model> {
init() { init(_ id: String? = nil) {
/**/print("MicIC.init") /**/print("MicIC.init")
super.init( super.init(
MicItem.Model(), MicItem.Model(),
@@ -26,13 +26,13 @@ extension MicItem {
// Нижеследующее предстоит сгенерить. // Нижеследующее предстоит сгенерить.
m m
.sink { v in Bus.send(K.MI, v) } .sink { v in Bus.send(Bus.keyId(K.MI, id), v) }
.store(in: &subscriptions) .store(in: &subscriptions)
pipeValue( pipeValue(
dbg: "activityD", dbg: "activityD",
sub: nil, sub: nil,
Bus.events.compactMap { Bus.convertKeyValue(K.activityDate, $0) }.map { (k: String, v: Date?) in v }.eraseToAnyPublisher(), Bus.events.compactMap { Bus.convertKeyValue(Bus.keyId(K.activityDate, id), $0) }.map { (k: String, v: Date?) in v }.eraseToAnyPublisher(),
{ {
$0.activityDate.value = $1 $0.activityDate.value = $1
$0.activityDate.isRecent = true $0.activityDate.isRecent = true
@@ -43,7 +43,7 @@ extension MicItem {
pipe( pipe(
dbg: "timeout", dbg: "timeout",
sub: nil, sub: nil,
Bus.events.compactMap { Bus.convertKeyValue(K.timeout, $0) }.map { (k: String, v: Bool) in v }.eraseToAnyPublisher(), Bus.events.compactMap { Bus.convertKeyValue(Bus.keyId(K.timeout, id), $0) }.map { (k: String, v: Bool) in v }.eraseToAnyPublisher(),
{ $0.timeout = true }, { $0.timeout = true },
{ $0.timeout = false } { $0.timeout = false }
) )

16
src/App.swift
View File

@@ -33,7 +33,8 @@ class AppDelegate: UIResponder, UIApplicationDelegate
/**/print("ИГР App.didFLWO") /**/print("ИГР App.didFLWO")
//testMic1() //testMic1()
testMic2() //testMic2()
testMic2_id("1")
return true return true
} }
@@ -57,7 +58,18 @@ class AppDelegate: UIResponder, UIApplicationDelegate
DispatchQueue.main.asyncAfter(deadline: .now() + 6) { DispatchQueue.main.asyncAfter(deadline: .now() + 6) {
Bus.send(Mic.K.activityDate, Date() + 7) Bus.send(Mic.K.activityDate, Date() + 7)
} }
}
// "1" func testMic2_id(_ id: String) {
DispatchQueue.main.asyncAfter(deadline: .now() + 2) {
Bus.send(Bus.keyId(Mic.K.activityDate, id), Date() + 2)
}
DispatchQueue.main.asyncAfter(deadline: .now() + 5) {
Bus.send(Bus.keyId(Mic.K.activityDate, id), Date() + 2)
}
DispatchQueue.main.asyncAfter(deadline: .now() + 6) {
Bus.send(Bus.keyId(Mic.K.activityDate, id), Date() + 3)
}
} }
} }