This commit is contained in:
Михаил Капелько
2023-12-28 18:32:00 +03:00
parent 4dbbcfdc22
commit 8e103fb4f4
2 changed files with 6 additions and 7 deletions

View File

@@ -93,7 +93,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 }.map { _ in }.eraseToAnyPublisher(), Bus.events.compactMap { Bus.convertKeyValue(K.join, $0) }.map { (k: String, v: Bool) in v }.map { _ in }.eraseToAnyPublisher(),
{ $0.join = true }, { $0.join = true },
{ $0.join = false } { $0.join = false }
) )

View File

@@ -1,10 +1,9 @@
def pipeBusSource(name, entity, busKey, structure, fmtBusPipe, fmtBusPipeToggle): def pipeBusSource(name, entity, busKey, structure, fmtBusPipe, fmtBusPipeToggle):
if "toggle" in entity.pipes[name]:
return fmtBusPipeToggle \
.replace("%BUS_KEY%", busKey) \
.replace("%BUS_VALUE_TYPE%", "Void")
valueType = structure.model.fields[name][0] valueType = structure.model.fields[name][0]
return fmtBusPipe \ fmt = fmtBusPipe
if "toggle" in entity.pipes[name]:
fmt = fmtBusPipeToggle
return fmt \
.replace("%BUS_KEY%", busKey) \ .replace("%BUS_KEY%", busKey) \
.replace("%BUS_VALUE_TYPE%", valueType) .replace("%BUS_VALUE_TYPE%", valueType)