Function dispatchWithTimeout

internal/bridge/transfer_e2e_test.go:148–164

dispatchWithTimeout runs registry.Dispatch in a goroutine and waits for completion.

(t *testing.T, b *Bridge, sessionID string, taskID uint32, spite *implantpb.Spite, timeout time.Duration)

// dispatchWithTimeout runs registry.Dispatch in a goroutine and waits for completion.
func dispatchWithTimeout(t *testing.T, b *Bridge, sessionID string, taskID uint32, spite *implantpb.Spite, timeout time.Duration) {
	t.Helper()
	ctx := b.moduleContext()
	done := make(chan bool, 1)
	go func() {
		ok := b.registry.Dispatch(ctx, sessionID, taskID, spite)
		done <- ok
	}()
	select {
	case ok := <-done:
		if !ok {
			t.Errorf("dispatch returned false for spite=%s", spite.Name)
		}
	case <-time.After(timeout):
		t.Fatalf("dispatch timed out after %v for spite=%s", timeout, spite.Name)
	}
}

// ===================================================================
// E2E: Direct Upload (small text file via Write tool)