(envelope Envelope)
| 1595 | } |
| 1596 | |
| 1597 | func envelopeRequiresThreadParticipantRouting(envelope Envelope) bool { |
| 1598 | return !envelope.IsDirected() && |
| 1599 | envelope.Surface != nil && |
| 1600 | *envelope.Surface == SurfaceThread && |
| 1601 | envelope.ThreadID != nil |
| 1602 | } |
| 1603 | |
| 1604 | func (r *Router) threadParticipantSet(ctx context.Context, envelope Envelope) (map[string]bool, error) { |
| 1605 | participants, err := r.threadParticipants.ListThreadParticipants( |
no test coverage detected