Lines Matching refs:WaitStarted
546 func (tp *testRoutingPublisher) WaitStarted() error { return tp.pub.WaitStarted() } func
571 if gotErr := pub.WaitStarted(); gotErr != nil {
582 if gotErr := pub.WaitStarted(); gotErr != nil {
654 if err := pub.WaitStarted(); err != nil {
716 if err := pub.WaitStarted(); err != nil {
766 if err := pub.WaitStarted(); err != nil {
804 if err := pub.WaitStarted(); err != nil {
834 if gotErr := pub.WaitStarted(); !test.ErrorHasMsg(gotErr, wantErr.Error()) {
860 if gotErr := pub.WaitStarted(); !test.ErrorHasMsg(gotErr, wantMsg) {
901 if gotErr := pub.WaitStarted(); gotErr != nil {
953 if gotErr := pub.WaitStarted(); gotErr != nil {
998 if gotErr := pub.WaitStarted(); gotErr != nil {