+1 -2

src/app/domain/brigade.gleam

reviewed

··· 19 19 use returned <- result.map(sql.query_members_id(ctx.db, brigade_id)) 20 20 21 21 use row <- list.each(returned.rows) 22 22 - use <- process.spawn 23 23 - user.broadcast(registry, row.id, message) 22 22 + process.spawn(fn() { user.broadcast(registry, row.id, message) }) 24 23 }

+5 -4

src/app/domain/occurrence.gleam

reviewed

··· 20 20 use returned <- result.map(sql.query_participants(ctx.db, occ_id)) 21 21 22 22 use row <- list.each(returned.rows) 23 23 - use <- process.spawn 24 24 - user.broadcast(registry, row.user_id, message) 23 23 + process.spawn(fn() { user.broadcast(registry, row.user_id, message) }) 25 24 } 26 25 27 26 ///  Notify subscribed users that a new occurrence has been added ··· 34 33 let members = group_registry.members(registry, topic) 35 34 36 35 use subject <- list.each(members) 37 37 - use <- process.spawn 38 38 - process.send(subject, msg.Domain(msg.OccurrenceCreated(id:, category:))) 36 36 + process.spawn(fn() { 37 37 + msg.Domain(msg.OccurrenceCreated(id:, category:)) 38 38 + |> process.send(subject, _) 39 39 + }) 39 40 }

+1 -2

src/app/domain/user.gleam

reviewed

··· 50 50 let members = group_registry.members(registry, topic) 51 51 52 52 use member <- list.each(members) 53 53 - use <- process.spawn 54 54 - process.send(member, message) 53 53 + process.spawn(fn() { process.send(member, message) }) 55 54 } 56 55 57 56 ///  Query the database to find the user's role name

+1 -2

src/app/web/socket.gleam

reviewed

··· 394 394 let members = group_registry.members(registry, ws_topic) 395 395 396 396 use member <- list.each(members) 397 397 - use <- process.spawn 398 398 - process.send(member, message) 397 397 + process.spawn(fn() { process.send(member, message) }) 399 398 } 400 399 401 400 fn send_response(