d
This commit is contained in:
@@ -9,7 +9,7 @@ extension Cord {
|
|||||||
public init(_ key: String) {
|
public init(_ key: String) {
|
||||||
Bus.send(
|
Bus.send(
|
||||||
key,
|
key,
|
||||||
v.eraseToAnyPublisher(),
|
v.map { true }.eraseToAnyPublisher(),
|
||||||
sub: &subscriptions
|
sub: &subscriptions
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -98,7 +98,7 @@ extension MeetupId {
|
|||||||
ctrl.pipe(
|
ctrl.pipe(
|
||||||
dbg: "finishL",
|
dbg: "finishL",
|
||||||
sub: nil,
|
sub: nil,
|
||||||
Bus.events.compactMap { Bus.convertKeyValue(K.finishLoading, $0) }.map { (k: String, v: Void) in v }.eraseToAnyPublisher(),
|
Bus.events.compactMap { Bus.convertKeyValue(K.finishLoading, $0) }.map { (k: String, v: Bool) in v }.eraseToAnyPublisher(),
|
||||||
{ $0.finishLoading = true },
|
{ $0.finishLoading = true },
|
||||||
{ $0.finishLoading = false }
|
{ $0.finishLoading = false }
|
||||||
)
|
)
|
||||||
@@ -124,7 +124,7 @@ extension MeetupId {
|
|||||||
ctrl.pipe(
|
ctrl.pipe(
|
||||||
dbg: "join",
|
dbg: "join",
|
||||||
sub: nil,
|
sub: nil,
|
||||||
Bus.events.compactMap { Bus.convertKeyValue(K.join, $0) }.map { (k: String, v: Void) in v }.eraseToAnyPublisher(),
|
Bus.events.compactMap { Bus.convertKeyValue(K.join, $0) }.map { (k: String, v: Bool) in v }.eraseToAnyPublisher(),
|
||||||
{ $0.join = true },
|
{ $0.join = true },
|
||||||
{ $0.join = false }
|
{ $0.join = false }
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -1,8 +1,5 @@
|
|||||||
def pipeBusSource(name, entity, busKey, structure, fmt):
|
def pipeBusSource(name, entity, busKey, structure, fmt):
|
||||||
valueType = structure.model.fields[name][0]
|
valueType = structure.model.fields[name][0]
|
||||||
if "toggle" in entity.pipes[name]:
|
|
||||||
valueType = "Void"
|
|
||||||
|
|
||||||
return fmt \
|
return fmt \
|
||||||
.replace("%BUS_KEY%", busKey) \
|
.replace("%BUS_KEY%", busKey) \
|
||||||
.replace("%BUS_VALUE_TYPE%", valueType)
|
.replace("%BUS_VALUE_TYPE%", valueType)
|
||||||
|
|||||||
Reference in New Issue
Block a user