-func (hc *testingHttpRtmgrStub) NextEvent(eventWaiter *httpEventWaiter) {
- hc.Lock()
- defer hc.Unlock()
- hc.eventWaiter = eventWaiter
+func (tc *testingHttpRtmgrStub) AllocNextEvent(nextAction bool) *HttpEventWaiter {
+ eventWaiter := &HttpEventWaiter{
+ resultChan: make(chan bool),
+ nextActionOk: nextAction,
+ }
+ eventWaiter.TestWrapper.Init("localhost:" + tc.port)
+ tc.NextEvent(eventWaiter)
+ return eventWaiter