Method BlockWrite

x/acpio/acp_conversation_test.go:172–178

BlockWrite sets up blocking for the next Write call and returns: - started: a channel that is closed when Write begins - done: a channel to close to unblock the Write

()

// - started: a channel that is closed when Write begins
// - done: a channel to close to unblock the Write
func (m *mockAgentIO) BlockWrite() (started chan struct{}, done chan struct{}) {
	m.mu.Lock()
	defer m.mu.Unlock()
	m.writeStarted = make(chan struct{})
	m.writeBlock = make(chan struct{})
	return m.writeStarted, m.writeBlock
}

func Test_NewACPConversation(t *testing.T) {
	mClock := quartz.NewMock(t)